From b4d123c10c0dbed2f3c563abc4fa7b1bb480c318 Mon Sep 17 00:00:00 2001
From: karsonto <karsontao@hotmail.com>
Date: Wed, 21 Feb 2024 13:47:05 +0800
Subject: [PATCH] bug fix

---
 .../eventmesh/storage/standalone/broker/MessageQueue.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java b/eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java
index 29ba120848..64b8fe4629 100644
--- a/eventmesh-storage-plugin/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java
+++ b/eventmesh-storage-plugin/eventmesh-storage-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;
         }