activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Christian Posta <christian.po...@gmail.com>
Subject Re: How to generate slow consumers.
Date Thu, 10 Oct 2013 17:04:27 GMT
And also consider setting prefetch limits on your consumer lower than
defaults. Slow consumers are  "slow" relative to how many messages have
been dispatched vs their prefetch limit.


On Thu, Oct 10, 2013 at 10:02 AM, Robert Davies <rajdavies@gmail.com> wrote:

> Its going to be difficult to setup a slow consumer with request/reply
> because you are limiting the rate at which messages are produced. A
> consumer is slow if can't keep pace with producer(s).
> What I would suggest you do is change your test a little, have your
> producer send messages asynchronously in blocks of a 1000 or so - and have
> more than one consumer, and put a blog sleep in one of the consumers (to
> simulate a slow application).
>
> On 10 Oct 2013, at 17:54, johnbing <bingjohn77@gmail.com> wrote:
>
> > Hi,
> >
> > I am using ActiveMQ-5.8.0. ActiveMQ internally takes care of handling the
> > slow consumers. But i have never seen any slow consumer in my broker.
> > I am trying to create a slow consumer but not successful yet --
> >
> > I have a test application(ping-pong) in which requester sends a message
> and
> > waits till responder respond with the reply message. and then send the
> next
> > message. So here I tried sending very big messages in (mb) So that
> responder
> > will take some time to respond, I thought responder may become a slow
> > consumer. But it was working properly. I have not seen any slow consumer
> > here.
> >
> > Can someone help me here to create a slow consumer.
> >
> > Thanks,
> > John
> >
> >
> >
> >
> > --
> > View this message in context:
> http://activemq.2283324.n4.nabble.com/How-to-generate-slow-consumers-tp4672583.html
> > Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>


-- 
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message