Merge pull request #6 from youzan/fix/not_removing_producer_in_add_ne…

…w_topic do not expire producer if pass in topic is NOT empty
youzan · Nov 14, 2018 · 0406910 · 0406910
2 parents e199b6b + 42c9183
commit 0406910
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/producer.go b/producer.go
@@ -931,6 +931,10 @@ func (self *TopicProducerMgr) queryLookupd(newTopic string) {
 		self.topics[topicName] = newProducerInfo
 		self.topicMtx.Unlock()
 	}
+	//leave removing expired producer to timer
+	if newTopic != "" {
+		return
+	}
 	self.producerMtx.Lock()
 	if len(allTopicParts) > 0 {
 		for k, p := range self.producers {