Haha :) Our scenario is that we have 200 consumers connecting to the server. They listen to the advisory queue so they know when queues are added / removed.
Each producer creates two new queues. A send queue & a recv queue. When a queue is created, the consumers subscribe to it. Main work loop is to loop through the send queues and call ReceiveNoWait() w/ a prefetch of 1. So every queue gets serviced in a round robin fashion. Occasionally we get the "The Consumer has been Closed" exception. Does that just mean that I tried to call ReceiveNoWait() after the producer queue was deleted and before the client got the "queue deleted" notification? -- View this message in context: http://activemq.2283324.n4.nabble.com/EXCEPTION-The-Consumer-has-been-Closed-tp4670465p4670467.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
