Fixing the mqtt java example a bit.

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>() {

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));