activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject [12/14] git commit: Added test for cleanSession=false and subscribing to wildcard dest
Date Fri, 11 Oct 2013 19:14:16 GMT
Added test for cleanSession=false and subscribing to wildcard dest

git-svn-id: https://svn.apache.org/repos/asf/activemq/activemq-apollo/trunk@1513607 13f79535-47bb-0310-9956-ffa450edef68


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

Branch: refs/heads/trunk
Commit: 354708f809d918dfb1ee69186bee0a0f33e3c5ad
Parents: 4cdcfa1
Author: Christian Posta <ceposta@apache.org>
Authored: Tue Aug 13 18:23:13 2013 +0000
Committer: Christian Posta <ceposta@apache.org>
Committed: Tue Aug 13 18:23:13 2013 +0000

----------------------------------------------------------------------
 .../activemq/apollo/mqtt/test/MqttExistingSessionTest.scala   | 7 +++++++
 1 file changed, 7 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-apollo/blob/354708f8/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
----------------------------------------------------------------------
diff --git a/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
b/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
index 572a7e4..287e46c 100644
--- a/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
+++ b/apollo-mqtt/src/test/scala/org/apache/activemq/apollo/mqtt/test/MqttExistingSessionTest.scala
@@ -39,4 +39,11 @@ class MqttExistingSessionTest extends MqttTestSupport {
     publish("existing/sub", "1", EXACTLY_ONCE)
     should_receive("1", "existing/sub")
   }
+
+  test("Subscribe") {
+    connect()
+    subscribe("foo/#")
+    publish("foo/A", "1", EXACTLY_ONCE)
+    should_receive("1", "foo/A")
+  }
 }


Mime
View raw message