diff --git a/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalTopicMessageStore.java b/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalTopicMessageStore.java index e8c16240ff..2f8c8b3094 100755 --- a/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalTopicMessageStore.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalTopicMessageStore.java @@ -68,7 +68,6 @@ public class JournalTopicMessageStore extends JournalMessageStore implements Top public void addMessage(ConnectionContext context, Message message) throws IOException { super.addMessage(context, message); - this.peristenceAdapter.checkpoint(false, false); } /**