node-amqp, RabbitMQ

Question

adresine ileti gönderemiyor rabbitmq-tutorials yüklüyüm, Ruby sürümü iyi çalışıyor ancak node.js sürümü ileti gönderemiyor. Neyin yanlış olduğunu bilmiyorum.

var amqp  = require('amqp'); 
var amqp_hacks = require('./amqp-hacks'); 

var connection = amqp.createConnection({host: 'localhost'}); 

connection.on('ready', function(){ 
    connection.publish('hello_node', 'Hello World!'); 
    console.log(" [x] Sent 'Hello World!'"); 

    amqp_hacks.safeEndConnection(connection); 
}); 

Hiçbir şey recv edemez node recv.jsnode send.js, basamak işlemini çalıştırdıktan sonra. ve rabbitmqctl list_queues, hello_node kuyruklarını göstermez.

Answer 1

Sırayı belirtmeniz ve sonra yayınlamanız gerekir. Bu sürüm aşağıdaki gibi çalışır:

var amqp  = require('amqp'); 
    var amqp_hacks = require('./amqp-hacks'); 

    var connection = amqp.createConnection({host: 'localhost'}); 

    connection.on('ready', function(){ 
      connection.queue('hello_node', {'durable': false}, function(q){ 
       connection.publish('hello_node', 'Hello World!'); 
       console.log(" [x] Sent 'Hello World!' to 'hello_node'"); 

       amqp_hacks.safeEndConnection(connection); 
      }); 
    });