sheetalrkadam
sheetalrkadam
Hi Akalend, Thanks for the quick response. Example: Task1: binding to RMQ and receiving msgs, posting the msgs to WorkerTasks for further processing. WorkerTask(1..n): Processing the received msg and sending...
Thank You for the response. I have couple of queries more. 1) AMQPQueue::sendConsumeCommand, consumes entire chunk of msgs available on RMQ (batch of data available on RMQ at any point...
Hi Akalend, We are using non blocking Consume. Every time we call the sendCommandConsume() with a timeout of 5 sec, channels are getting incremented. Could you please let us know...