1) I have one publisher (put message in queue) which should be allowed to put messages asap (no delay) in different queues,
and
2) I want to have consumer/consumers who can read messages from the queue at controlled speed (defined by me).
My stackoverflow and google search is telling me to use prefetch, or flow control, or qos methods.
I am referring to http://www.squaremobius.net/amqp.node/channel_api.html
Having unlimited bandwidth from the publisher side, and having a correlationId for each message published are my two primary requirements. What's the best option among all those I mentioned. I am looking for more code snippets and difference between results while implementing each of these methods to fulfill my purpose. What will be the pros and cons with each of these methods?
via manntsheth
No comments:
Post a Comment