RabbitMQの接続のためのAMQP（Node.js）の接続が早すぎる

Question

私は以下のコードを持っています。

TypeError: Cannot read property 'assertQueue' of undefined 
    at /var/www/myapp/dashboard/routes.js:195:39 
    at /var/www/myapp/node_modules/amqplib/lib/callback_model.js:46:16 
    at /var/www/myapp/node_modules/amqplib/lib/callback_model.js:61:10 
    at /var/www/myapp/node_modules/amqplib/lib/callback_model.js:74:5 

私ははconn.closeをコメントアウトした場合（）、およびコードが正常に動作し、私はコードがch.assertQueueの実行前に、早すぎるCONNをクローズしようとしていると思います。この問題を解決する最良の方法は何ですか？

amqp.connect('amqp://localhost', function(err, conn) { 
    conn.createChannel(function(err, ch) { 
    var q = 'blast_queue'; 
    var msg = blast.id; 

    ch.assertQueue(q, {durable: true}); 
    ch.sendToQueue(q, new Buffer(msg), {persistent: true}); 
    console.log(" [x] Sent '%s'", msg); 
    }); 
    conn.close(); 
}); 

Answer 1

これは、conn.createChannelのコールバック関数が実行される前に接続が終了するために発生します。 は、それを修正しますが、コールバック関数の内部接続を閉じる行に移動するには：

amqp.connect('amqp://localhost', function(err, conn) { 
    conn.createChannel(function(err, ch) { 
    var q = 'blast_queue'; 
    var msg = blast.id; 

    ch.assertQueue(q, {durable: true}); 
    ch.sendToQueue(q, new Buffer(msg), {persistent: true}); 
    console.log(" [x] Sent '%s'", msg); 
    conn.close(); // <=== close connection here 
    }); 
});