Oh ok, i get it now.
Well, i cannot guarantee about the publish method (but i find it highly
unlikely that it needs to reinstantiate the queue).
But on my app, i subscribe to a queue, and it works as expected (fires
callback when a message is delivered).
Could you write a gist to test it?
On 05/17/2012 10:50 AM, Cassio Melo wrote:
Hi Dan, by "request" I mean "exchange", sorry. I know the queue has to
be configured each time. Let me rephrase the problem.
In the exchange above, the result is redirected to the queue
"incoming", which just prints out the message.
If I publish in the exchange for the second time, i.e,
"exchange.publish('msg_queue'... )", the queue "incoming" seems to be
not instantiated and throws this error:
Error: NOT_FOUND - no queue 'incoming' in vhost '/'
at Queue._onMethod (/Users/cassiomelo/code/cubix/cubix_nodejs/
node_modules/amqp/amqp.js
So, the question is, is it really necessary to instantiate the queue,
ie queue = connection.queue('incoming',...) before publishing in the
exchange again?
On May 16, 7:04 pm, Dan Milon<[email protected]> wrote:
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 [email protected]
To unsubscribe from this group, send email to
[email protected]
For more options, visit this group at
http://groups.google.com/group/nodejs?hl=en?hl=en
