camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [1/2] git commit: Improved JMX handling on ActiveMQ broker for tests
Date Fri, 05 Sep 2014 07:02:27 GMT
Repository: camel
Updated Branches:
  refs/heads/master c3d69ce40 -> fd02839e5


Improved JMX handling on ActiveMQ broker for tests

Disabled jmx for tests that don't need to use it and also add
AvailablePortFinder to dinamically assing JMX connector port when
needed.

Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1f3b6269
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1f3b6269
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1f3b6269

Branch: refs/heads/master
Commit: 1f3b62698e83852de7d9f50c90cb310b32803e71
Parents: 11b3282
Author: Cristiano Nicolai <cristiano.nicolai@gmail.com>
Authored: Thu Aug 21 02:06:18 2014 +1000
Committer: Cristiano Nicolai <cristiano.nicolai@gmail.com>
Committed: Thu Aug 21 02:06:18 2014 +1000

----------------------------------------------------------------------
 .../apache/camel/component/sjms/SimpleJmsComponentTest.java    | 2 +-
 .../camel/component/sjms/consumer/AsyncConsumerFalseTest.java  | 2 +-
 .../camel/component/sjms/consumer/AsyncConsumerInOutTest.java  | 2 +-
 .../sjms/consumer/InOnlyTopicDurableConsumerTest.java          | 2 +-
 .../component/sjms/jms/ConnectionFactoryResourceTest.java      | 2 +-
 .../org/apache/camel/component/sjms/jms/SessionPoolTest.java   | 2 +-
 .../apache/camel/component/sjms/support/JmsTestSupport.java    | 6 +++---
 .../sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java | 2 +-
 .../BatchTransactedConcurrentMultipleRouteConsumersTest.java   | 2 +-
 .../component/sjms/tx/BatchTransactedQueueConsumerTest.java    | 2 +-
 .../component/sjms/tx/BatchTransactedQueueProducerTest.java    | 2 +-
 .../sjms/tx/BatchTransactedTopicConsumerMultipleRouteTest.java | 2 +-
 .../component/sjms/tx/BatchTransactedTopicConsumerTest.java    | 2 +-
 .../component/sjms/tx/BatchTransactedTopicProducerTest.java    | 2 +-
 .../component/sjms/tx/TransactedConcurrentConsumersTest.java   | 2 +-
 .../sjms/tx/TransactedConsumersMultipleRouteTest.java          | 2 +-
 .../camel/component/sjms/tx/TransactedQueueConsumerTest.java   | 2 +-
 .../camel/component/sjms/tx/TransactedQueueProducerTest.java   | 2 +-
 .../camel/component/sjms/tx/TransactedTopicConsumerTest.java   | 2 +-
 .../camel/component/sjms/tx/TransactedTopicProducerTest.java   | 2 +-
 20 files changed, 22 insertions(+), 22 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java
index 5ae1dab..bb519ec 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/SimpleJmsComponentTest.java
@@ -34,7 +34,7 @@ public class SimpleJmsComponentTest extends CamelTestSupport {
     protected RouteBuilder createRouteBuilder() throws Exception {
         return new RouteBuilder() {
             public void configure() {
-                ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false&broker.useJmx=true");
+                ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false&broker.useJmx=false");
                 SjmsComponent component = new SjmsComponent();
                 component.setConnectionFactory(connectionFactory);
                 getContext().addComponent("sjms", component);

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java
index 594522e..ce0642f 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerFalseTest.java
@@ -46,7 +46,7 @@ public class AsyncConsumerFalseTest extends CamelTestSupport {
         camelContext.addComponent("async", new MyAsyncComponent());
 
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
-                "vm://broker?broker.persistent=false");
+                "vm://broker?broker.persistent=false&broker.useJmx=false");
         SjmsComponent component = new SjmsComponent();
         component.setConnectionFactory(connectionFactory);
         camelContext.addComponent("sjms", component);

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java
index 4cefd1e..940c8f2 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/AsyncConsumerInOutTest.java
@@ -50,7 +50,7 @@ public class AsyncConsumerInOutTest extends CamelTestSupport {
         camelContext.addComponent("async", new MyAsyncComponent());
 
         ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
-                "vm://broker?broker.persistent=false");
+                "vm://broker?broker.persistent=false&broker.useJmx=false");
         SjmsComponent component = new SjmsComponent();
         component.setConnectionFactory(connectionFactory);
         camelContext.addComponent("sjms", component);

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java
index 2420476..6c3a92f 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/consumer/InOnlyTopicDurableConsumerTest.java
@@ -29,7 +29,7 @@ import org.junit.Test;
 public class InOnlyTopicDurableConsumerTest extends CamelTestSupport {
     
     private static final String CONNECTION_ID = "test-connection-1";
-    private static final String BROKER_URI = "vm://durable.broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://durable.broker?broker.persistent=false&broker.useJmx=false";
     
     @Override
     protected boolean useJmx() {

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/ConnectionFactoryResourceTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/ConnectionFactoryResourceTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/ConnectionFactoryResourceTest.java
index 79aa04d..fa295bb 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/ConnectionFactoryResourceTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/ConnectionFactoryResourceTest.java
@@ -34,7 +34,7 @@ public class ConnectionFactoryResourceTest {
 
     @Before
     public void setup() {
-        connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false");
+        connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false&broker.useJmx=false");
     }
 
     @After

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/SessionPoolTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/SessionPoolTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/SessionPoolTest.java
index 2e41eea..dead399 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/SessionPoolTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/jms/SessionPoolTest.java
@@ -36,7 +36,7 @@ public class SessionPoolTest {
 
     @Before
     public void setup() {
-        connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false");
+        connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false&broker.useJmx=false");
     }
 
     @After

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/JmsTestSupport.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/JmsTestSupport.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/JmsTestSupport.java
index 7b3e1f7..b4cdf3c 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/JmsTestSupport.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/support/JmsTestSupport.java
@@ -56,10 +56,10 @@ public class JmsTestSupport extends CamelTestSupport {
     @Override
     protected void doPreSetup() throws Exception {
         deleteDirectory("target/activemq-data");
-
-        brokerUri = "tcp://localhost:" + AvailablePortFinder.getNextAvailable(33333);
-
         broker = new BrokerService();
+        final int port = AvailablePortFinder.getNextAvailable(33333);
+        brokerUri = "tcp://localhost:" + port;
+        broker.getManagementContext().setConnectorPort(AvailablePortFinder.getNextAvailable(port
+ 1));
         configureBroker(broker);
         startBroker();
     }

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java
index 440def5..ba62001 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleConsumerTest.java
@@ -23,7 +23,7 @@ import org.junit.Test;
  */
 public class BatchTransactedConcurrentMultipleConsumerTest extends TransactedConsumerSupport
{
     
-    private static final String BROKER_URI = "vm://btcmc_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://btcmc_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleRouteConsumersTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleRouteConsumersTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleRouteConsumersTest.java
index 2c04ea7..b853ac2 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleRouteConsumersTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedConcurrentMultipleRouteConsumersTest.java
@@ -24,7 +24,7 @@ import org.junit.Test;
  */
 public class BatchTransactedConcurrentMultipleRouteConsumersTest extends TransactedConsumerSupport
{
     
-    private static final String BROKER_URI = "vm://btcmrc_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://btcmrc_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueConsumerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueConsumerTest.java
index 8fbd662..d7c8f62 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueConsumerTest.java
@@ -24,7 +24,7 @@ import org.junit.Test;
  */
 public class BatchTransactedQueueConsumerTest extends TransactedConsumerSupport {
     
-    private static final String BROKER_URI = "vm://btqc_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://btqc_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueProducerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueProducerTest.java
index ea7209e..fe40725 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedQueueProducerTest.java
@@ -24,7 +24,7 @@ import org.junit.Test;
  * for a Queue Producer.
  */
 public class BatchTransactedQueueProducerTest extends BatchTransactedProducerSupport {
-    private static final String BROKER_URI = "vm://btqpt_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://btqpt_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * Verify that after processing a {@link BatchMessage} twice with 30

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerMultipleRouteTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerMultipleRouteTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerMultipleRouteTest.java
index 1e9cc5b..21aaa6e 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerMultipleRouteTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerMultipleRouteTest.java
@@ -24,7 +24,7 @@ import org.junit.Test;
  */
 public class BatchTransactedTopicConsumerMultipleRouteTest extends TransactedConsumerSupport
{
     
-    private static final String BROKER_URI = "vm://bttcmr_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://bttcmr_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
index 24ac52e..062decb 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicConsumerTest.java
@@ -24,7 +24,7 @@ import org.junit.Test;
  */
 public class BatchTransactedTopicConsumerTest extends TransactedConsumerSupport {
     
-    private static final String BROKER_URI = "vm://bttc_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://bttc_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicProducerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicProducerTest.java
index 31b26e7..c494973 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/BatchTransactedTopicProducerTest.java
@@ -24,7 +24,7 @@ import org.junit.Test;
  * for a Topic Producer.
  */
 public class BatchTransactedTopicProducerTest extends BatchTransactedProducerSupport {
-    private static final String BROKER_URI = "vm://bttpt_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://bttpt_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * Verify that after processing a {@link BatchMessage} twice with 30

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java
index e97769b..35ebf96 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConcurrentConsumersTest.java
@@ -23,7 +23,7 @@ import org.junit.Test;
  */
 public class TransactedConcurrentConsumersTest extends TransactedConsumerSupport {
     
-    private static final String BROKER_URI = "vm://btqc_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://btqc_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumersMultipleRouteTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumersMultipleRouteTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumersMultipleRouteTest.java
index 34c004c..f2b491a 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumersMultipleRouteTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedConsumersMultipleRouteTest.java
@@ -23,7 +23,7 @@ import org.junit.Test;
  */
 public class TransactedConsumersMultipleRouteTest extends TransactedConsumerSupport {
     
-    private static final String BROKER_URI = "vm://btqc_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://btqc_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueConsumerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueConsumerTest.java
index 8f3f51a..0080df9 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueConsumerTest.java
@@ -20,7 +20,7 @@ import org.junit.Test;
 
 public class TransactedQueueConsumerTest extends TransactedConsumerSupport {
     
-    private static final String BROKER_URI = "vm://tqc_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://tqc_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java
index 5cdf3e4..6fae5e0 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedQueueProducerTest.java
@@ -61,7 +61,7 @@ public class TransactedQueueProducerTest extends CamelTestSupport {
      */
     @Override
     protected CamelContext createCamelContext() throws Exception {
-        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false&broker.useJmx=true");
+        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false&broker.useJmx=false");
         CamelContext camelContext = super.createCamelContext();
         SjmsComponent component = new SjmsComponent();
         component.setConnectionFactory(connectionFactory);

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicConsumerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicConsumerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicConsumerTest.java
index 99cc3d4..c2104e6 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicConsumerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicConsumerTest.java
@@ -20,7 +20,7 @@ import org.junit.Test;
 
 public class TransactedTopicConsumerTest extends TransactedConsumerSupport {
     
-    private static final String BROKER_URI = "vm://ttc_test_broker?broker.persistent=false&broker.useJmx=true";
+    private static final String BROKER_URI = "vm://ttc_test_broker?broker.persistent=false&broker.useJmx=false";
 
     /**
      * We want to verify that when consuming from a single destination with

http://git-wip-us.apache.org/repos/asf/camel/blob/1f3b6269/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
----------------------------------------------------------------------
diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
index ddc0f63..5d90ce7 100644
--- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
+++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/tx/TransactedTopicProducerTest.java
@@ -62,7 +62,7 @@ public class TransactedTopicProducerTest extends CamelTestSupport {
      */
     @Override
     protected CamelContext createCamelContext() throws Exception {
-        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false&broker.useJmx=true");
+        ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory("vm://broker?broker.persistent=false&broker.useJmx=false");
         ConnectionFactoryResource connectionResource = new ConnectionFactoryResource();
         connectionResource.setConnectionFactory(connectionFactory);
         connectionResource.setClientId("test-connection-1");


Mime
View raw message