From 8931aac98ee284f251cc582e493159f588746d55 Mon Sep 17 00:00:00 2001 From: Robert Davies Date: Tue, 16 Oct 2007 10:53:51 +0000 Subject: [PATCH] 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 --- .../store/kahadaptor/KahaReferenceStoreAdapter.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java index 4f12fd9836..c725b91e40 100644 --- a/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java +++ b/activemq-core/src/main/java/org/apache/activemq/store/kahadaptor/KahaReferenceStoreAdapter.java @@ -26,6 +26,7 @@ import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; +import org.apache.activemq.broker.ConnectionContext; import org.apache.activemq.command.ActiveMQDestination; import org.apache.activemq.command.ActiveMQQueue; import org.apache.activemq.command.ActiveMQTopic; @@ -114,6 +115,11 @@ public class KahaReferenceStoreAdapter extends KahaPersistenceAdapter implements } 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() { return storeValid;