I think you have to consider the Virtual Topic, http://activemq.apache.org/virtual-destinations.html
At 2013-03-16 13:04:41,jaikit <jktsa...@gmail.com> wrote: > >I currently have a Topic and there are multiple clients which are subscribed >to my Topic. I am running with default prefetch for each client. Now the >problem is if one of the client is slow, it slows down other subscribers. I >am thinking to play by setting low prefetch for slow consumer. But this >solution does not work because in my case slow clients are random and they >keep changing over a period of time (based on the backend they are >communicating). Hence I cannot keep low prefetch for one of the client. > >Solution which I am thinking to prototype below solution: >I will be keeping queues for each subscriber and now Given a Topic - pool of >threads will remove events from Topic and copy the events to my queue. Now >since I have queue for each subscriber, each client is independent of each >other. I will set prefetch limit to each queue. Once that limit is reached, >I will drop the events. Drawback: Memory is required for each queue now. > >I would like some views about above solution or any other solution which you >think might fit for my case. > >Thanks > > > >-- >View this message in context: >http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic-to-full-Solution-tp4664784.html >Sent from the ActiveMQ - User mailing list archive at Nabble.com.
