diff --git a/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java b/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java index 80c26e0e9a..042174d63a 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java @@ -263,7 +263,6 @@ public class JournalMessageStore implements MessageStore { size += message.getSize(); - iterator.remove(); message.decrementReferenceCount(); // Commit the batch if it's getting too big