This is an automated email from the ASF dual-hosted git repository. dinglei pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git
The following commit(s) were added to refs/heads/master by this push: new aeb448a [ISSUE #117]Fix timeout failed in syncSendOrderly. aeb448a is described below commit aeb448a58c2a5c191063be3a49f8c056dd4cce58 Author: shaolsh <40844985+shao...@users.noreply.github.com> AuthorDate: Tue Aug 20 15:24:07 2019 +0800 [ISSUE #117]Fix timeout failed in syncSendOrderly. [ISSUE #117]Fix timeout failed in syncSendOrderly --- .../src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java index 6b5d06c..be4d194 100644 --- a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java +++ b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/core/RocketMQTemplate.java @@ -283,7 +283,7 @@ public class RocketMQTemplate extends AbstractMessageSendingTemplate<String> imp */ public SendResult syncSendOrderly(String destination, Object payload, String hashKey, long timeout) { Message<?> message = this.doConvert(payload, null, null); - return syncSendOrderly(destination, message, hashKey, producer.getSendMsgTimeout()); + return syncSendOrderly(destination, message, hashKey, timeout); } /** * Same to {@link #asyncSend(String, Message, SendCallback)} with send timeout and delay level specified in addition.