fix: remove subscription consumer instead of re-registering

(cherry picked from commit 8e4ea7d)
camunda · Apr 14, 2022 · 79204a5 · 79204a5
1 parent 7eeeffc
commit 79204a5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dispatcher/src/main/java/io/camunda/zeebe/dispatcher/Subscription.java b/dispatcher/src/main/java/io/camunda/zeebe/dispatcher/Subscription.java
@@ -82,7 +82,7 @@ public void registerConsumer(final ActorCondition consumer) {
 
   @Override
   public void removeConsumer(final ActorCondition consumer) {
-    actorConditions.registerConsumer(consumer);
+    actorConditions.removeConsumer(consumer);
   }
 
   protected long getLimit() {