activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r741329 - in /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store: AbstractMessageStore.java journal/JournalMessageStore.java
Date Thu, 05 Feb 2009 22:42:43 GMT
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);
     }



Mime
View raw message