#!/usr/bin/env node

var net = require('net'),
    util = require('util'),
    stomp = require('stomped');

var args = process.argv.slice(2);
var test_queue = args[0] || "q";

var message_count = 0;

client = stomp.createClient('127.0.0.1', 61613);

client.on('connected', function() {
  client.subscribe(test_queue);
  client.on('message', function(queue, message) {
    message_count += 1;
  });
});

client.on('disconnected', function() {
  process.exit(1);
});

setInterval(function() {
	if (message_count > 0) {
		console.log('messages:'+message_count);
		message_count = 0;
	}
}, 1000);