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/04/15 09:17:50 UTC
[incubator-tubemq] branch master updated: [TUBEMQ-66]
TubeSingleSessionFactory shutdown bug (#54)
This is an automated email from the ASF dual-hosted git repository.
gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
The following commit(s) were added to refs/heads/master by this push:
new 9e6a26b [TUBEMQ-66] TubeSingleSessionFactory shutdown bug (#54)
9e6a26b is described below
commit 9e6a26b926e52bb43c1aeecfda7378f2b80dc1ad
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);
}
}