You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2009/02/05 23:42:43 UTC
svn commit: r741329 - in
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/store:
AbstractMessageStore.java journal/JournalMessageStore.java
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);
}