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
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
>http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic-to-full-Solution-tp4664784p4664919.html
>Sent from the ActiveMQ - User mailing list archive at Nabble.com.
--
Wangyin
suonayi2...@163.com
put an infinite sleep in one of the consumer. In
that case the messages are never expired. Ideally fast consumer should
consumer messages and slow consumer should expire those messages.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic
that is not happening. Can
you please some suggest some solution for this.
Appreciate any help, pointers.
Thanks
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic-to-full-Solution-tp4664784p4664903.html
Sent from the ActiveMQ - User
alDestinationInterceptor();
> interceptor.setVirtualDestinations(new VirtualDestination[] {
> virtualTopic });
> broker.setDestinationInterceptors(new DestinationInterceptor[] {
> interceptor });
> broker.start();
>
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic-to-full-Solution-tp4664784p4664856.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
--
http://redhat.com
http://blog.garytully.com
setVirtualDestinations(new VirtualDestination[] {
virtualTopic });
broker.setDestinationInterceptors(new DestinationInterceptor[] {
interceptor });
broker.start();
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic-to-full-Solut
in context:
http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic-to-full-Solution-tp4664784p4664855.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
physically to queue for each topic
> subscriber ?
>
> Thanks for pointer.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Random-slow-Subscribers-causing-Topic-to-full-Solution-tp4664784p4664808.html
> Sent from the ActiveMQ - User
