rabbitmq Sıradaki iletiyi zorlama. Node.JS

Question

Nasıl bağlantı kuracağım. Bu kodu çalıştırdığınızda node.js ve AMQP modülünü

this.conn.exchange(name, options, function(ex) { 
    console.log('Exchange ready'); 
    this.exchange = ex; 

    var next = this.cb; 
    delete this.cb; 
    ex.publish('cbQueue', { 
     id: 'asd', 
     deliveryId: 'asdasd' 
    }); 

    !!next && next(null); 

}.bind(this)); 

kullanarak, bu değişimi hazır olduğunu gösterir, ancak http://localhost:15672/#/queues üzerinde cbQueue boş.

Fikriniz var mı? niye ya ? Rabbitmq tamamlanmadan önce kodunuzun çıkması büyük olasılıkla

Answer 1

.

Bunu test etmek, izin, bu sonraki çağırmadan önce yarım saniye geciktirecek next

setTimeout(function(){ 
    !!next && next(null); 
}, 500); 

çağrınızda etrafında setTimeout koymak