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.

Reply via email to