You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by go...@apache.org on 2020/05/13 03:24:22 UTC
[incubator-tubemq] 05/07: [TUBEMQ-66] TubeSingleSessionFactory
shutdown bug (#54)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch release-0.3.0
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
commit 3e8d817473e75c9a5680b712437598aa5688cab9
Author: Tboy <gu...@immomo.com>
AuthorDate: Wed Apr 15 17:17:30 2020 +0800
[TUBEMQ-66] TubeSingleSessionFactory shutdown bug (#54)
---
.../java/org/apache/tubemq/client/factory/TubeSingleSessionFactory.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/tubemq-client/src/main/java/org/apache/tubemq/client/factory/TubeSingleSessionFactory.java b/tubemq-client/src/main/java/org/apache/tubemq/client/factory/TubeSingleSessionFactory.java
index b9ffa4d..33c31ae 100644
--- a/tubemq-client/src/main/java/org/apache/tubemq/client/factory/TubeSingleSessionFactory.java
+++ b/tubemq-client/src/main/java/org/apache/tubemq/client/factory/TubeSingleSessionFactory.java
@@ -45,7 +45,6 @@ public class TubeSingleSessionFactory implements MessageSessionFactory {
if (referenceCounter.incrementAndGet() == 1) {
RpcConfig config = TubeClientConfigUtils.getRpcConfigByClientConfig(tubeClientConfig, true);
clientFactory.configure(config);
- referenceCounter.incrementAndGet();
baseSessionFactory = new TubeBaseSessionFactory(clientFactory, tubeClientConfig);
}
}