Fix unable to close consumer after unsubscribe in Shared Subscription (…

…apache#283)
hrsakai · Jun 17, 2020 · 1e00fb6 · 1e00fb6
1 parent 62203d7
commit 1e00fb6
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pulsar/consumer_partition.go b/pulsar/consumer_partition.go
@@ -184,6 +184,10 @@ func (pc *partitionConsumer) internalUnsubscribe(unsub *unsubscribeRequest) {
 	if err != nil {
 		pc.log.WithError(err).Error("Failed to unsubscribe consumer")
 		unsub.err = err
+		// Set the state to ready for closing the consumer
+		pc.state = consumerReady
+		// Should'nt remove the consumer handler
+		return
 	}
 
 	pc.conn.DeleteConsumeHandler(pc.consumerID)