What do you mean "request"? Incoming HTTP request? Why would you connect to the queue again and again every time?
About the connection.queue, yes you have to provide the configuration each time. I think it is the way amqp is defined, and not node-amqp issue.
On 05/16/2012 06:06 PM, Cassio Melo wrote:
Do I really need to instantiate the queue "queue = connection.queue(...)" every time I want to use it? Server (node.js): queue = connection.queue('incoming', { //<--- DO I REALLY NEED THAT FOR EVERY REQUEST? durable : true, exclusive : false }, function() {}); queue.subscribe(function(msg) { // Unsubcribe here. Maybe there is something like a once listener? console.log("RECEIVED: "+msg) //res.send(msg.data); queue.unsubscribe(ctag); res.redirect('/home'); }).addCallback(function(ok) { ctag = ok.consumerTag; }); exchange.publish('msg_queue', 'functional!', { // request replyTo: 'incoming' }); If queue = connection.queue(...); is instantiated with the server, the first request using the queue is successful, but the following requests throw an error: Error: NOT_FOUND - no queue 'incoming' in vhost '/' at Queue._onMethod (/Users/cassiomelo/code/cubix/cubix_nodejs/ node_modules/amqp/amqp.js
-- Job Board: http://jobs.nodejs.org/ Posting guidelines: https://github.com/joyent/node/wiki/Mailing-List-Posting-Guidelines You received this message because you are subscribed to the Google Groups "nodejs" group. To post to this group, send email to nodejs@googlegroups.com To unsubscribe from this group, send email to nodejs+unsubscr...@googlegroups.com For more options, visit this group at http://groups.google.com/group/nodejs?hl=en?hl=en