diff --git a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java index 25f94cae..4213cb4b 100644 --- a/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java +++ b/rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java @@ -221,24 +221,16 @@ public SendReceipt syncSendNormalMessage(String destination, byte[] payload) { */ public SendReceipt syncSendGrpcMessage(String destination, Message message, Duration messageDelayTime, String messageGroup) { if (Objects.isNull(message) || Objects.isNull(message.getPayload())) { - log.error("send request message failed. destination:{}, message is null ", destination); throw new IllegalArgumentException("`message` and `message.payload` cannot be null"); } SendReceipt sendReceipt = null; try { org.apache.rocketmq.client.apis.message.Message rocketMsg = this.createRocketMQMessage(destination, message, messageDelayTime, messageGroup); Producer grpcProducer = this.getProducer(); - try { - sendReceipt = grpcProducer.send(rocketMsg); - log.info("Send message successfully, messageId={}", sendReceipt.getMessageId()); - } catch (Throwable t) { - log.error("Failed to send message", t); - } + return grpcProducer.send(rocketMsg); } catch (Exception e) { - log.error("send request message failed. destination:{}, message:{} ", destination, message); throw new MessagingException(e.getMessage(), e); } - return sendReceipt; } @@ -311,7 +303,6 @@ public CompletableFuture asyncSendDelayMessage(String destination, public CompletableFuture asyncSend(String destination, Message message, Duration messageDelayTime, String messageGroup, CompletableFuture future) { if (Objects.isNull(message) || Objects.isNull(message.getPayload())) { - log.error("send request message failed. destination:{}, message is null ", destination); throw new IllegalArgumentException("`message` and `message.payload` cannot be null"); } Producer grpcProducer = this.getProducer(); @@ -329,7 +320,6 @@ public CompletableFuture asyncSend(String destination, Message m }); } } catch (Exception e) { - log.error("send request message failed. destination:{}, message:{} ", destination, message); throw new MessagingException(e.getMessage(), e); } return future0; @@ -358,7 +348,6 @@ public Pair sendMessageInTransaction(String destinatio */ public Pair sendTransactionMessage(String destination, Message message) { if (Objects.isNull(message) || Objects.isNull(message.getPayload())) { - log.error("send request message failed. destination:{}, message is null ", destination); throw new IllegalArgumentException("`message` and `message.payload` cannot be null"); } final SendReceipt sendReceipt; @@ -368,9 +357,7 @@ public Pair sendTransactionMessage(String destination, try { transaction = grpcProducer.beginTransaction(); sendReceipt = grpcProducer.send(rocketMsg, transaction); - log.info("Send transaction message successfully, messageId={}", sendReceipt.getMessageId()); } catch (ClientException e) { - log.error("send request message failed. destination:{}, message:{} ", destination, message); throw new RuntimeException(e); } return new Pair<>(sendReceipt, transaction);