activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: Slow consumer problem
Date Mon, 05 Jun 2006 14:15:53 GMT
BTW I wonder if you were hitting this issue which was just fixed in
subversion (thanks for the patch Danielius!)

http://issues.apache.org/activemq/browse/AMQ-736

On 6/5/06, James Strachan <james.strachan@gmail.com> wrote:
> BTW are you positive you are using persistent queues? i.e. setting hte
> delivery mode on your MessageProducer to be persistent?
>
> On 6/5/06, Frank Baxter <frank@baxres.org> wrote:
> >
> > I've read through the slow consumer issues, but I still can't figure out how
> > to solve this problem.
> >
> > I'm using AMQ 4.0 with persistent queues.  I've got several message
> > producers that are reading information from an external system and creating
> > JMS messages.  They do this in bursts, sometimes with a high input rate.
> > The messages end up around 300K in size.  I use auto-ack on these producers.
> >
> > My consumers are slow, and sometimes are not even running.  I'm expecting
> > the JMS system to queue the messages up in the persistent storage.  When my
> > consumers are running they will pull messages off as they can.  I use
> > client-ack on the consumers (they are actually a chain of consumer/producers
> > with decision points).
> >
> > It seems that the default behavior for AMQ is to slow down my producers when
> > the messages queue up.  Eventually (seems to be around 2500 messages) they
> > stop completely.  This causes a problem with my initial producers because
> > they are also receiving inputs from the external (non JMS) system.  With AMQ
> > they are failing because they are timing out talking to that other system.
> >
> > What I'm looking for is a way to remove that auto-slow down logic in my
> > producers.  I want these producers to write messages as fast as possible so
> > I don't impact my external system.  Does anyone have any ideas on how I can
> > achieve this with AMQ?
> >
> > BTW, I have this system implemented and working using JBoss MQ, but I'm
> > looking to replace it due to performance issues, especially when large
> > queues exist and the JBoss server restarts.
> >
> > --
> > View this message in context: http://www.nabble.com/Slow-consumer-problem-t1733329.html#a4709829
> > Sent from the ActiveMQ - User forum at Nabble.com.
> >
> >
>
>
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message