bug fix

karsonto · Feb 21, 2024 · b4d123c · b4d123c
1 parent cd5799b
commit b4d123c
Showing 1 changed file with 1 addition 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,7 +236,7 @@ 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;
         }