skip publishAssignEventAsync when disabled

apache · Oct 23, 2024 · 3b9e857 · 3b9e857
1 parent 483c343
commit 3b9e857
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java b/.../org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java
@@ -626,7 +626,7 @@ private long getNextVersionId(ServiceUnitStateData data) {
     }
 
     public CompletableFuture<String> publishAssignEventAsync(String serviceUnit, String broker) {
-        if (!validateChannelState(Started, true)) {
+        if (!validateChannelState(Started, true) || channelState == Disabled) {
             return CompletableFuture.failedFuture(
                     new IllegalStateException("Invalid channel state:" + channelState.name()));
         }