svn commit: r741329 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store: AbstractMessageStore.java journal/JournalMessageStore.java

[chirino]

Author: chirino
Date: Thu Feb  5 22:42:42 2009
New Revision: 741329

URL: http://svn.apache.org/viewvc?rev=741329&view=rev
Log:
Opps miss a couple of commits with that last change.

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java?rev=741329&r1=741328&r2=741329&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java
 Thu Feb  5 22:42:42 2009
@@ -46,6 +46,6 @@
     public void setMemoryUsage(MemoryUsage memoryUsage) {
     }
     
-    public void setBatch(MessageId messageId) throws IOException {
+    public void setBatch(MessageId messageId) throws IOException, Exception {
     }
 }

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java?rev=741329&r1=741328&r2=741329&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java
 Thu Feb  5 22:42:42 2009
@@ -412,7 +412,7 @@
     }
 
     @Override
-    public void setBatch(MessageId messageId) {
+    public void setBatch(MessageId messageId) throws Exception {
         peristenceAdapter.checkpoint(true, true);
         longTermStore.setBatch(messageId);
     }