echo_consumer.js

// publish `message` to the "/echo" topic, and call `callback` on response
module.exports = function echo(connection, message, callback) {
  connection.subscribe('/echo', callback);
  connection.publish('/echo', message);
};