listener.js

var amqp = require('amqp');
var con = amqp.createConnection({ host: 'localhost' });
console.log('created connection instance');
con.on('ready', function() {
	console.log('ready');
	con.queue('ping', function(q) {
		console.log('listening to queue ping');
		q.bind('#');
		q.subscribe(function(message) {
			console.log('arguments:', arguments);
		});
	});
});
con.on('error', function(err) {
	console.log('error:', err);
});
process.stdin.resume();

ping.js

var amqp = require('amqp');
var con = amqp.createConnection({}, {
	defaultExchangeName: 'amq.topic'
});
con.on('ready', function() {
	con.publish('ping', { pong: 'pong' }, {}, function() {
		console.log('ping callback:', arguments);
	});
});