You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/10/27 06:59:28 UTC

[rocketmq] branch develop updated: [ISSUE#3430] fix the problem that setting parameter mqClientApiTimeout doesn't take effect (#3431)

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 1657475  [ISSUE#3430] fix the problem that setting parameter mqClientApiTimeout doesn't take effect (#3431)
1657475 is described below

commit 1657475997733133fea6a1be14b8a22cc5730698
Author: haozhijie9527 <47...@users.noreply.github.com>
AuthorDate: Wed Oct 27 14:59:12 2021 +0800

    [ISSUE#3430] fix the problem that setting parameter mqClientApiTimeout doesn't take effect (#3431)
    
    * [maven-release-plugin] prepare release rocketmq-all-4.9.2
    
    * [maven-release-plugin] prepare for next development iteration
    
    * fix the problem that setting parameter mqClientApiTimeout doesn't take effect
    
    Co-authored-by: tigerlee <ti...@apache.org>
    Co-authored-by: haozhijie <ha...@kuaishou.com>
---
 client/src/main/java/org/apache/rocketmq/client/ClientConfig.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
index b2c043e..8d7f5a1 100644
--- a/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
+++ b/client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
@@ -158,6 +158,7 @@ public class ClientConfig {
         this.useTLS = cc.useTLS;
         this.namespace = cc.namespace;
         this.language = cc.language;
+        this.mqClientApiTimeout = cc.mqClientApiTimeout;
     }
 
     public ClientConfig cloneClientConfig() {
@@ -176,6 +177,7 @@ public class ClientConfig {
         cc.useTLS = useTLS;
         cc.namespace = namespace;
         cc.language = language;
+        cc.mqClientApiTimeout = mqClientApiTimeout;
         return cc;
     }