var sys = require('util');
var stomp = require('stomp');
var stomp_args = {
port: 61613,
host: process.argv[2] ? process.argv[2] : 'localhost',
debug: false,
login: 'xtomp',
passcode: 'passcode',
};
var client = new stomp.Stomp(stomp_args);
client.connect();
client.on('connected', function() {
client.send({
destination: 'memtop-a',
ack: 'client',
receipt: 'send',
body : "{\"test\": true}"
});
});
client.on('receipt', function(id) {
if (id === "send") {
client.disconnect();
process.exit(0);
} else {
console.error("receipt error: " + id);
process.exit(1);
}
});
client.on('error', function(error_frame) {
console.error("Error");
console.error(error_frame.body);
process.exit(1);
});
process.on('SIGINT', function() {
client.disconnect();
process.exit(2);
});