Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

no need to call force() on commit as the reference store gets rebuilt on failure 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@585109 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-10-16 10:53:51 +00:00
parent cb234b32d3
commit 8931aac98e
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java
View File

@ -26,6 +26,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicLong;
import org.apache.activemq.broker.ConnectionContext;
import org.apache.activemq.command.ActiveMQDestination; import org.apache.activemq.command.ActiveMQDestination;
import org.apache.activemq.command.ActiveMQQueue; import org.apache.activemq.command.ActiveMQQueue;
import org.apache.activemq.command.ActiveMQTopic; import org.apache.activemq.command.ActiveMQTopic;
@ -115,6 +116,11 @@ public class KahaReferenceStoreAdapter extends KahaPersistenceAdapter implements
super.stop(); super.stop();
} }
public void commitTransaction(ConnectionContext context) throws IOException {
//we don;t need to force on a commit - as the reference store
//is rebuilt on a non clean shutdown
}
public boolean isStoreValid() { public boolean isStoreValid() {
return storeValid; return storeValid;
} }