const carrotmq = require('carrotmq');
//var rabbitmqSchema = require('rabbitmq-schema'); 
const rabbitmqSchema = carrotmq.schema;
 
//see https://www.npmjs.com/package/rabbitmq-schema 
const schema = new rabbitmqSchema({
    exchange: 'exchange0',
    type: 'topic',
    bindings: [{
      routingPattern: 'foo.bar.#',
      destination: {
        queue: 'fooQueue',
        messageSchema: {}
      }
    }]
});
const mq = new carrotmq('amqp://localhost', schema);
 
const publisher = new carrotmq('amqp://localhost'); //also can use without schema 
 
mq.queue('fooQueue', function (data){
    console.log(data);
    this.ack();
    //this.nack(); 
    //this.reject(); 
    //this.cancel(); cancel this consumer; 
    this.reply({date: new Date}); //reply to message.properties.relyTo 
    this.carrotmq //carrotmq instrance 
    this.channel  //current channel 
    return Promise.reject(); // or throw new Error('some thing happened') will execute `this.reject()` if this message hadn't been ack 
});
 
mq.sendToQueue('queue', {msg: 'message'});
mq.publish('exchange', 'foo.bar.key', {msg: 'hello world!'});

mq.rpc('queue', {data: new Date})
.then((reply)=>{
  reply.ack();
  console.log(reply.data); //some reply result 
});

 
//{ 
//    routingPattern: 'rpc.#', 
//   destination: { 
//      queue: 'rpcQueue', 
//      messageSchema: {} 
//    } 
//  } 
 
app.queue('rpcQueue', function (data) {
  this.reply(data);
  this.ack();
}, true);   /* true here for mark this queue is a rpc queue,
carrotmq will wrap real content with json {replyTo: 'queue', content: {buffer}}
for replyTo properties,because of rabbitMQ will ignore
message sent to exchange with vanilla replyTo ,
if server side doesn't using carrotmq ,just handle {replyTo: 'queue', content: {buffer}}*/
 
let time = new Date();
app.rpcExchange('exchange0', 'rpc.rpc', {time})
.then(function (reply){
  reply.ack();
  console.log(reply.data)//{time: time} 
})

mq.on('ready', function(){});

mq.on('error', function (err){});

mq.on('message', function (data){
  data.channel; //channel object 
  data.queue   //queue name 
  data.message  //message object 
})