9

私はrabbitmq-tutorialsを試しています。ruby バージョンは正常に動作しますが、node.js バージョンはメッセージを送信できません。何が悪いのかわかりません。

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);
});

を実行した後node send.js、実行中のプロセスnode recv.jsは何も受信できません。キューを表示しrabbitmqctl list_queuesません。hello_node

4

1 に答える 1

5

キューを指定してから公開する必要があります。そのバージョンは動作するはずです:

    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);
            });
    });
于 2013-04-22T19:27:36.387 に答える