[#888] incr instanceCount in once and fmt codes (#888)

apache · Oct 17, 2022 · 43186ad · 43186ad
1 parent b3ede3a
commit 43186ad
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/consumer/consumer.go b/consumer/consumer.go
@@ -276,9 +276,7 @@ func (dc *defaultConsumer) start() error {
 		retryTopic := internal.GetRetryTopic(dc.consumerGroup)
 		sub := buildSubscriptionData(retryTopic, MessageSelector{TAG, _SubAll})
 		dc.subscriptionDataTable.Store(retryTopic, sub)
-	}
 
-	if dc.model == Clustering {
 		dc.option.ChangeInstanceNameToPID()
 		dc.storage = NewRemoteOffsetStore(dc.consumerGroup, dc.client, dc.client.GetNameSrv())
 	} else {

diff --git a/internal/client.go b/internal/client.go
@@ -384,8 +384,10 @@ func GetOrNewRocketMQClient(option ClientOptions, callbackCh chan interface{}) R
 func (c *rmqClient) Start() {
 	//ctx, cancel := context.WithCancel(context.Background())
 	//c.cancel = cancel
-	atomic.AddInt32(&c.instanceCount, 1)
 	c.once.Do(func() {
+
+		atomic.AddInt32(&c.instanceCount, 1)
+
 		if !c.option.Credentials.IsEmpty() {
 			c.remoteClient.RegisterInterceptor(remote.ACLInterceptor(c.option.Credentials))
 		}