activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cepo...@apache.org
Subject svn commit: r1513995 - /activemq/activemq-apollo/trunk/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
Date Wed, 14 Aug 2013 18:08:17 GMT
Author: ceposta
Date: Wed Aug 14 18:08:17 2013
New Revision: 1513995

URL: http://svn.apache.org/r1513995
Log:
updated test for https://issues.apache.org/jira/browse/APLO-335

Modified:
    activemq/activemq-apollo/trunk/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala

Modified: activemq/activemq-apollo/trunk/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala?rev=1513995&r1=1513994&r2=1513995&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
Wed Aug 14 18:08:17 2013
@@ -41,9 +41,16 @@ class MqttExistingSessionTest extends Mq
   }
 
   test("Subscribe") {
+
     connect()
-    subscribe("foo/#")
-    publish("foo/A", "1", EXACTLY_ONCE)
-    should_receive("1", "foo/A")
+
+    var client2 = create_client
+    client2.setCleanSession(false);
+    client2.setClientId("another")
+    connect(c = client2)
+
+    subscribe(topic = "1/#", c = client2)
+    publish("1/data/apps/crm/Opportunity/60", "2", EXACTLY_ONCE)
+    should_receive(body = "2", topic = "1/data/apps/crm/Opportunity/60", c = client2)
   }
 }



Mime
View raw message