Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-17 07:24:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Opps miss a couple of commits with that last change.

Browse Source 
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@741329 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2009-02-05 22:42:42 +00:00
parent 180b0ec4ab
commit 273933378b
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/store/AbstractMessageStore.java
View File

@ -46,6 +46,6 @@ abstract public class AbstractMessageStore implements MessageStore {
public void setMemoryUsage(MemoryUsage memoryUsage) { public void setMemoryUsage(MemoryUsage memoryUsage) {
} }
public void setBatch(MessageId messageId) throws IOException { public void setBatch(MessageId messageId) throws IOException, Exception {
} }
} }

2
activemq-core/src/main/java/org/apache/activemq/store/journal/JournalMessageStore.java
View File

@ -412,7 +412,7 @@ public class JournalMessageStore extends AbstractMessageStore {
} }
@Override @Override
public void setBatch(MessageId messageId) { public void setBatch(MessageId messageId) throws Exception {
peristenceAdapter.checkpoint(true, true); peristenceAdapter.checkpoint(true, true);
longTermStore.setBatch(messageId); longTermStore.setBatch(messageId);
} }