diff --git a/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java b/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java
index a383e4dc18..f5bf1db7dd 100644
--- a/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java
+++ b/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java
@@ -46,6 +46,6 @@ abstract public class AbstractMessageStore implements MessageStore {
     public void setMemoryUsage(MemoryUsage memoryUsage) {
     }
     
-    public void setBatch(MessageId messageId) throws IOException {
+    public void setBatch(MessageId messageId) throws IOException, Exception {
     }
 }
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 8c445a0e3b..b419a44050 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
@@ -412,7 +412,7 @@ public class JournalMessageStore extends AbstractMessageStore {
     }
 
     @Override
-    public void setBatch(MessageId messageId) {
+    public void setBatch(MessageId messageId) throws Exception {
         peristenceAdapter.checkpoint(true, true);
         longTermStore.setBatch(messageId);
     }