diff --git a/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalTopicMessageStore.java b/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalTopicMessageStore.java index 7059376311..26a813805d 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalTopicMessageStore.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/journal/QuickJournalTopicMessageStore.java @@ -82,7 +82,6 @@ public class QuickJournalTopicMessageStore extends QuickJournalMessageStore impl public void addMessage(ConnectionContext context, Message message) throws IOException { super.addMessage(context, message); - this.peristenceAdapter.checkpoint(false, false); } /**