Skip to content

Commit cc36cfe

Browse files
committed
Optimize log output
1 parent 32bf105 commit cc36cfe

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

rocketmq-v5-client-spring-boot/src/main/java/org/apache/rocketmq/client/core/RocketMQClientTemplate.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -227,11 +227,10 @@ public SendReceipt syncSendGrpcMessage(String destination, Message<?> message, D
227227
try {
228228
org.apache.rocketmq.client.apis.message.Message rocketMsg = this.createRocketMQMessage(destination, message, messageDelayTime, messageGroup);
229229
Producer grpcProducer = this.getProducer();
230-
sendReceipt = grpcProducer.send(rocketMsg);
230+
return grpcProducer.send(rocketMsg);
231231
} catch (Exception e) {
232232
throw new MessagingException(e.getMessage(), e);
233233
}
234-
return sendReceipt;
235234
}
236235

237236

0 commit comments

Comments
 (0)