Updated Branches: refs/heads/trunk a912d6d5c -> 51cf06be5
Fixing the mqtt java example a bit. Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/6773b8ff Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/6773b8ff Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/6773b8ff Branch: refs/heads/trunk Commit: 6773b8ff76f08f27e734ae385e038e4f48eadac4 Parents: a912d6d Author: Hiram Chirino <[email protected]> Authored: Thu Oct 10 11:32:29 2013 -0400 Committer: Hiram Chirino <[email protected]> Committed: Thu Oct 10 11:38:07 2013 -0400 ---------------------------------------------------------------------- .../examples/mqtt/java/src/main/java/example/Listener.java | 1 + .../examples/mqtt/java/src/main/java/example/Publisher.java | 3 +++ 2 files changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/6773b8ff/assembly/src/release/examples/mqtt/java/src/main/java/example/Listener.java ---------------------------------------------------------------------- diff --git a/assembly/src/release/examples/mqtt/java/src/main/java/example/Listener.java b/assembly/src/release/examples/mqtt/java/src/main/java/example/Listener.java index cd6b9c8..7569a0b 100644 --- a/assembly/src/release/examples/mqtt/java/src/main/java/example/Listener.java +++ b/assembly/src/release/examples/mqtt/java/src/main/java/example/Listener.java @@ -78,6 +78,7 @@ class Listener { } count ++; } + ack.run(); } }); connection.connect(new Callback<Void>() { http://git-wip-us.apache.org/repos/asf/activemq/blob/6773b8ff/assembly/src/release/examples/mqtt/java/src/main/java/example/Publisher.java ---------------------------------------------------------------------- diff --git a/assembly/src/release/examples/mqtt/java/src/main/java/example/Publisher.java b/assembly/src/release/examples/mqtt/java/src/main/java/example/Publisher.java index c58866f..c876d64 100644 --- a/assembly/src/release/examples/mqtt/java/src/main/java/example/Publisher.java +++ b/assembly/src/release/examples/mqtt/java/src/main/java/example/Publisher.java @@ -71,6 +71,9 @@ class Publisher { queue.removeFirst().await(); } + if( i % 1000 == 0 ) { + System.out.println(String.format("Sent %d messages.", i)); + } } queue.add(connection.publish(topic, new AsciiBuffer("SHUTDOWN"), QoS.AT_LEAST_ONCE, false));
