Re: Re:Re: Random slow Subscribers - causing Topic to full - Solution ?

No both are are subscribed to individual queues. I have CompositeDestination set up ..where messages are forwarded to both the queues. -- View this message in context: http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic-to-full-Solution-tp4664784p4664924.html Sent from

Re: Random slow Subscribers - causing Topic to full - Solution ?

I found an old post with same problem (non deterministic behaviour of collecting expired messages) https://issues.apache.org/jira/browse/AMQ-1112 I am using build 5.8. Can someone please let me know if there is any deterministic way of expiring messages ? My scenario: I have 2 consumers and I p

Re: Random slow Subscribers - causing Topic to full - Solution ?

Thanks for the answer. I tried setting up expiry and timetolive and it does expire the message. But If one my consumer takes a message and never acks - than messages are expired for both fast and slow consumers. What I would like is atleast fast consumer receive the message. But unfortunately tha

Discard messages for Slow consumers on "Queue"

Hi Docs, I have running Active MQ 5.8 and have setup VirtualDestinations (2 queues). One of the queue is slow and it is not discarding messages. Could some one please suggest how should I enable discarding messages for that queue ? please find below my code snippet: broker.setDeleteAllMe

Re: Random slow Subscribers - causing Topic to full - Solution ?

Currently I have 2 consumers set up - which are consuming from Queues. I have disabled producerflowcontrol, setMemoryLimit to 1, queueprefetch = 10, topicprefetch = 10. I have added infinite sleep in consumer1 and I ran the load test with 90 events. My expectation is consumer1 discarding all

Re: Random slow Subscribers - causing Topic to full - Solution ?

I was able to forward messages from Topics to Queue using VirtualDestination. But I am not able to figure out how do I configure my consumer to drop messages if they are consuming slow. I got below snippet from ActiveMQ documentation. Non-durable queues A slow consumer is not really an issue wit

Re: Re:Random slow Subscribers - causing Topic to full - Solution ?

If Virtual Topic - "create queues for each topic subscriber and replicates messages to each one." - than this is exactly what i need. Can you confirm if Virtual Topic replicates messages physically to queue for each topic subscriber ? Thanks for pointer. -- View this message in context: http