move close channle behind producer state changed

apache · Jul 19, 2023 · f46c663 · f46c663
1 parent dbf81be
commit f46c663
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pulsar/producer_partition.go b/pulsar/producer_partition.go
@@ -1266,12 +1266,12 @@ func (p *partitionProducer) ReceivedSendReceipt(response *pb.CommandSendReceipt)
 
 func (p *partitionProducer) internalClose(req *closeProducer) {
 	defer close(req.doneCh)
-	defer close(p.dataChan)
-	defer close(p.cmdChan)
 	if !p.casProducerState(producerReady, producerClosing) {
 		return
 	}
 
+	defer close(p.dataChan)
+	defer close(p.cmdChan)
 	p.log.Info("Closing producer")
 	for {
 		if len(p.dataChan) == 0 {