You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2015/10/14 16:10:20 UTC

qpid-jms git commit: QPIDJMS-129: disable concurrentStoreAndDispatch to hopefully avoid hitting AMQ-5664 during test run

Repository: qpid-jms
Updated Branches:
  refs/heads/master dd6b7fc6e -> 541bccc18


QPIDJMS-129: disable concurrentStoreAndDispatch to hopefully avoid hitting AMQ-5664 during test run


Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/541bccc1
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/541bccc1
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/541bccc1

Branch: refs/heads/master
Commit: 541bccc18b777edd8d365a942bbe53061e6b91c0
Parents: dd6b7fc
Author: Robert Gemmell <ro...@apache.org>
Authored: Wed Oct 14 15:09:56 2015 +0100
Committer: Robert Gemmell <ro...@apache.org>
Committed: Wed Oct 14 15:09:56 2015 +0100

----------------------------------------------------------------------
 .../org/apache/qpid/jms/support/QpidJmsTestSupport.java   | 10 ++++++++++
 1 file changed, 10 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/541bccc1/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java
----------------------------------------------------------------------
diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java
index 520feeb..fa64fac 100644
--- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java
+++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/support/QpidJmsTestSupport.java
@@ -139,6 +139,14 @@ public class QpidJmsTestSupport {
         return false;
     }
 
+    protected boolean isConcurrentStoreAndDispatchQueues() {
+        return false;
+    }
+
+    protected boolean isConcurrentStoreAndDispatchTopics() {
+        return false;
+    }
+
     protected boolean isAdvisorySupport() {
         return false;
     }
@@ -169,6 +177,8 @@ public class QpidJmsTestSupport {
         if (isPersistent()) {
             KahaDBStore kaha = new KahaDBStore();
             kaha.setDirectory(new File(KAHADB_DIRECTORY + "/" + name));
+            kaha.setConcurrentStoreAndDispatchQueues(isConcurrentStoreAndDispatchQueues());
+            kaha.setConcurrentStoreAndDispatchTopics(isConcurrentStoreAndDispatchTopics());
             brokerService.setPersistenceAdapter(kaha);
         }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org