var amqp = require('amqplib/callback_api');

amqp.connect('amqp://guest:guest@121.40.92.176', function(err, conn) {
    conn.createChannel(function(err, ch) {
        var ex = 'open_id';
        ch.assertExchange(ex, 'fanout', {durable: false});
        ch.assertQueue('', {exclusive: true}, function(err, q) {
            console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", q.queue);
            ch.bindQueue(q.queue, ex, '');
            ch.consume(q.queue, function(msg) {
                console.log(" [x] %s", msg.content.toString());
            }, {noAck: true});
        });
    });
});