Clean up examples, add a sleep and be more informative.

Author: benjaminws

examples/stomp-consumer.js

@@ -36,6 +36,7 @@ client.on('connected', function() {
 client.on('message', function(message) {
     //console.log("HEADERS: " + sys.inspect(message.headers));
     //console.log("BODY: " + message.body);
+    console.log("Got message: " + message.headers['message-id']);
     client.ack(message.headers['message-id']);
     messages++;
 });

examples/stomp-producer.js

@@ -24,6 +24,11 @@ var queue = '/queue/test_stomp';
 
 client.connect();
 
+function sleep(milliSeconds) {
+    var startTime = new Date().getTime();
+    while (new Date().getTime() < startTime + milliSeconds);
+}
+
 client.on('connected', function() {
     num = num || 1000;
     for (var i = 0; i < num; i++) {
@@ -32,6 +37,7 @@ client.on('connected', function() {
             'body': 'Testing\n\ntesting1\n\ntesting2 ' + i,
             'persistent': 'true'
         }, receipt);
+        sleep(250);
     }
     console.log('Produced ' + num + ' messages');
     client.disconnect();