var amqp = require('amqp');

var connection = amqp.createConnection({
  host: '192.168.64.10',
  port: 5672
});

// Wait for connection to become established.
connection.on('ready', function () {
  console.log('ready');
  // Use the default 'amq.topic' exchange
  connection.queue('my-queue', function (q) {
      // Catch all messages
      q.bind('#');

      // Receive messages
      q.subscribe(function (message) {
        // Print messages to stdout
        console.log('got a message: ', message);
      });
      q.subscribe(function(message) {
        console.log('got a message 2: ', message);
      })
      connection.publish('my-queue', { hello: 'world' });
      connection.publish('my-queue', { hello: 'world' });
      connection.publish('my-queue', { hello: 'world' });
      connection.publish('my-queue', { hello: 'world' });
      connection.publish('my-queue', { hello: 'world' });
      connection.publish('my-queue', { hello: 'world' });
      
  });
});