Closed x-wk closed 1 month ago
try { Message<?> message = MessageBuilder.withPayload(payloadBuilder.build()) .setHeader(RocketMQHeaders.KEYS, keys) .build(); // send SendReceipt sendReceipt = rocketMQClientTemplate.syncSendNormalMessage(MQTopics.XXX_TOPIC, message); // no exception? if (sendReceipt == null) { throw new RuntimeError("1111", "Failure"); } } catch (Exception e) { throw new RuntimeError("1111", "Failure"); }
Ugly...🤮
Ugly...🤮