[ISSUE #4778] Fix Standalone MessageQueue does not down counter when …

…dequeue (#4779) * bug fix * bug fix
apache · Feb 21, 2024 · c93fc3e · c93fc3e
1 parent 1a5e06c
commit c93fc3e
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -236,10 +236,11 @@ private void enqueue(MessageEntity messageEntity) {
      * @return The MessageEntity object at the head of the queue.
      */
     private MessageEntity dequeue() {
-        MessageEntity item = items[takeIndex++];
+        final MessageEntity item = items[takeIndex++];
         if (takeIndex == items.length) {
             takeIndex = 0;
         }
+        count--;
         notFull.signalAll();
         return item;
     }