bug fix

karsonto · Feb 21, 2024 · cd5799b · cd5799b
1 parent 1a5e06c
commit cd5799b
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java b/...standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java
@@ -240,6 +240,7 @@ private MessageEntity dequeue() {
         if (takeIndex == items.length) {
             takeIndex = 0;
         }
+        count--;
         notFull.signalAll();
         return item;
     }