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; }