[GitHub] [pulsar] AnonHxy commented on a diff in pull request #19934: [fix][broker] Return if AbstractDispatcherSingleActiveConsumer closed

AnonHxy commented on code in PR #19934: URL: https://github.com/apache/pulsar/pull/19934#discussion_r1159250344 ## pulsar-broker/src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumersTest.java: ## @@ -94,6 +94,15 @@ public

[GitHub] [pulsar] AnonHxy commented on a diff in pull request #19934: [fix][broker] Return if AbstractDispatcherSingleActiveConsumer closed

AnonHxy commented on code in PR #19934: URL: https://github.com/apache/pulsar/pull/19934#discussion_r1156653236 ## pulsar-broker/src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumersTest.java: ## @@ -94,6 +94,15 @@ public

[GitHub] [pulsar] AnonHxy commented on a diff in pull request #19934: [fix][broker] Return if AbstractDispatcherSingleActiveConsumer closed

AnonHxy commented on code in PR #19934: URL: https://github.com/apache/pulsar/pull/19934#discussion_r1154064739 ## pulsar-broker/src/test/java/org/apache/pulsar/broker/service/nonpersistent/NonPersistentStickyKeyDispatcherMultipleConsumersTest.java: ## @@ -94,6 +94,15 @@ public

[GitHub] [pulsar] AnonHxy commented on a diff in pull request #19934: [fix][broker] Return if AbstractDispatcherSingleActiveConsumer closed

AnonHxy commented on code in PR #19934: URL: https://github.com/apache/pulsar/pull/19934#discussion_r1154064376 ## pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentStickyKeyDispatcherMultipleConsumers.java: ## @@ -102,6 +102,11 @@ public class P