activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject git commit: Remove unneeded broker stop / start at test begin.
Date Mon, 28 Jul 2014 19:57:24 GMT
Repository: activemq
Updated Branches:
  refs/heads/trunk 73908d649 -> 8d04e2be8


Remove unneeded broker stop / start at test begin. 

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/8d04e2be
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/8d04e2be
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/8d04e2be

Branch: refs/heads/trunk
Commit: 8d04e2be8ec66ac54a1d62f2a2ba50320bfc0802
Parents: 73908d6
Author: Timothy Bish <tabish121@gmail.com>
Authored: Mon Jul 28 15:57:08 2014 -0400
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Mon Jul 28 15:57:08 2014 -0400

----------------------------------------------------------------------
 .../activemq/transport/mqtt/MQTTTest.java       | 20 +++++++++-----------
 1 file changed, 9 insertions(+), 11 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/8d04e2be/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
----------------------------------------------------------------------
diff --git a/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
b/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
index fc91f27..8734d65 100644
--- a/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
+++ b/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
@@ -16,6 +16,14 @@
  */
 package org.apache.activemq.transport.mqtt;
 
+import static org.junit.Assert.assertArrayEquals;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertNotEquals;
+import static org.junit.Assert.assertNotNull;
+import static org.junit.Assert.assertNull;
+import static org.junit.Assert.assertTrue;
+import static org.junit.Assert.fail;
+
 import java.net.ProtocolException;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -27,6 +35,7 @@ import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 import java.util.regex.Pattern;
+
 import javax.jms.BytesMessage;
 import javax.jms.Connection;
 import javax.jms.Destination;
@@ -35,13 +44,6 @@ import javax.jms.MessageProducer;
 import javax.jms.Session;
 import javax.jms.TextMessage;
 
-import static org.junit.Assert.assertArrayEquals;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNotEquals;
-import static org.junit.Assert.assertNotNull;
-import static org.junit.Assert.assertNull;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.fail;
 import org.apache.activemq.ActiveMQConnection;
 import org.apache.activemq.broker.region.policy.LastImageSubscriptionRecoveryPolicy;
 import org.apache.activemq.broker.region.policy.PolicyEntry;
@@ -1045,9 +1047,6 @@ public class MQTTTest extends MQTTTestSupport {
 
     @Test(timeout = 60 * 1000)
     public void testPublishDollarTopics() throws Exception {
-        stopBroker();
-        startBroker();
-
         MQTT mqtt = createMQTTConnection();
         final String clientId = "publishDollar";
         mqtt.setClientId(clientId);
@@ -1123,7 +1122,6 @@ public class MQTTTest extends MQTTTestSupport {
         }
 
         jmsConn.close();
-
     }
 
     @Test(timeout = 30 * 10000)


Mime
View raw message