Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #843

This commit is contained in:
Martyn Taylor 2016-10-14 10:23:22 +01:00
parent 7d03bcf434 6a9e4c05e8
commit 6052f7a25d
2 changed files with 16 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
examples/protocols/mqtt/basic-pubsub/readme.html
View File

@ -87,26 +87,28 @@ under the License.
<p>Subscriptions in MQTT are realised by subscribing to a particular Topic. Each Topic has an address <p>Subscriptions in MQTT are realised by subscribing to a particular Topic. Each Topic has an address
and a quality of service level (QoS level). Subscriptions also support wildcards. In the code below we and a quality of service level (QoS level). Subscriptions also support wildcards. In the code below we
subscribe to a Topic with address "mqtt/example/publish" and also a wildcard address "mqtt/#" which will subscribe to a Topic with address "mqtt/example/publish", a wildcard address "test/#" which will
match anything starting with "mqtt/".</p> match anything starting with "test/" and also a wildcard "foo/+/bar", where + matches a single level of the hierarchy (foo/something/bar)</p>
<pre class="prettyprint"> <pre class="prettyprint">
Topic[] topics = { new Topic("mqtt/example/publish", QoS.AT_LEAST_ONCE), new Topic("mqtt/#", QoS.EXACTLY_ONCE) }; Topic[] topics = { new Topic("mqtt/example/publish", QoS.AT_LEAST_ONCE), new Topic("test/#", QoS.EXACTLY_ONCE), new Topic("foo/+/bar", QoS.AT_LEAST_ONCE) };
connection.subscribe(topics); connection.subscribe(topics);
</pre> </pre>
<li>3. Sending messages</li> <li>3. Sending messages</li>
<p>There is no type system in MQTT, messages simply consist of a number of bytes. Below we send two messages with <p>There is no type system in MQTT, messages simply consist of a number of bytes. Below we send three messages with
UTF8 encoded strings (as a byte array). Notice the second message is sent to "mqtt/test" which should match UTF8 encoded strings (as a byte array). Notice the second message is sent to "test/test" which should match
our wildcard subscription we defined previously.</p> the first wildcard subscription we defined previously. The third message is sent to "foo/1/bar", which matches the second wildcard subscription.</p>
<pre class="prettyprint"> <pre class="prettyprint">
String payload1 = "This is message 1"; String payload1 = "This is message 1";
String payload2 = "This is message 2"; String payload2 = "This is message 2";
String payload3 = "This is message 3";
connection.publish("mqtt/example/publish", payload1.getBytes(), QoS.AT_LEAST_ONCE, false); connection.publish("mqtt/example/publish", payload1.getBytes(), QoS.AT_LEAST_ONCE, false);
connection.publish("mqtt/test", payload2.getBytes(), QoS.AT_MOST_ONCE, false); connection.publish("mqtt/test", payload2.getBytes(), QoS.AT_MOST_ONCE, false);
connection.publish("foo/1/bar", payload3.getBytes(), QoS.AT_MOST_ONCE, false);
</pre> </pre>
<li>4. Receiving messages</li> <li>4. Receiving messages</li>
@ -119,9 +121,11 @@ under the License.
<pre class="prettyprint"> <pre class="prettyprint">
Message message1 = connection.receive(5, TimeUnit.SECONDS); Message message1 = connection.receive(5, TimeUnit.SECONDS);
Message message2 = connection.receive(5, TimeUnit.SECONDS); Message message2 = connection.receive(5, TimeUnit.SECONDS);
Message message3 = connection.receive(5, TimeUnit.SECONDS);
System.out.println(new String(message1.getPayload())); System.out.println(new String(message1.getPayload()));
System.out.println(new String(message2.getPayload())); System.out.println(new String(message2.getPayload()));
System.out.println(new String(message3.getPayload()));
</pre> </pre>
</o1> </o1>

8
examples/protocols/mqtt/basic-pubsub/src/main/java/org/apache/activemq/artemis/mqtt/example/MQTTBasicPubSubExample.java
View File

@ -39,23 +39,27 @@ public class MQTTBasicPubSubExample {
System.out.println("Connected to Artemis"); System.out.println("Connected to Artemis");
// Subscribe to topics // Subscribe to topics
Topic[] topics = {new Topic("mqtt/example/publish", QoS.AT_LEAST_ONCE), new Topic("mqtt/#", QoS.EXACTLY_ONCE)}; Topic[] topics = {new Topic("mqtt/example/publish", QoS.AT_LEAST_ONCE), new Topic("test/#", QoS.EXACTLY_ONCE), new Topic("foo/+/bar", QoS.AT_LEAST_ONCE)};
connection.subscribe(topics); connection.subscribe(topics);
System.out.println("Subscribed to topics."); System.out.println("Subscribed to topics.");
// Publish Messages // Publish Messages
String payload1 = "This is message 1"; String payload1 = "This is message 1";
String payload2 = "This is message 2"; String payload2 = "This is message 2";
String payload3 = "This is message 3";
connection.publish("mqtt/example/publish", payload1.getBytes(), QoS.AT_LEAST_ONCE, false); connection.publish("mqtt/example/publish", payload1.getBytes(), QoS.AT_LEAST_ONCE, false);
connection.publish("mqtt/test", payload2.getBytes(), QoS.AT_MOST_ONCE, false); connection.publish("test/test", payload2.getBytes(), QoS.AT_MOST_ONCE, false);
connection.publish("foo/1/bar", payload3.getBytes(), QoS.AT_MOST_ONCE, false);
System.out.println("Sent messages."); System.out.println("Sent messages.");
Message message1 = connection.receive(5, TimeUnit.SECONDS); Message message1 = connection.receive(5, TimeUnit.SECONDS);
Message message2 = connection.receive(5, TimeUnit.SECONDS); Message message2 = connection.receive(5, TimeUnit.SECONDS);
Message message3 = connection.receive(5, TimeUnit.SECONDS);
System.out.println("Received messages."); System.out.println("Received messages.");
System.out.println(new String(message1.getPayload())); System.out.println(new String(message1.getPayload()));
System.out.println(new String(message2.getPayload())); System.out.println(new String(message2.getPayload()));
System.out.println(new String(message3.getPayload()));
} }
} }