Re: Large PendingQueueSize values for subscriptions on a queue with one message

2007-08-23 Thread David Sitsky
Hi Rob, I thought that would be your answer - fair enough. I've attached a unit test which demonstrates the problem. I tried to make the code as small as possible. In this situation, the issue (program hangs) seems to happen when QUEUE_PREFETCH_SIZE == 1 and NUM_WORKERS = 2 (90% of the time

Re: Large PendingQueueSize values for subscriptions on a queue with one message

2007-08-23 Thread Rob Davies
could you build a junit test case to demonstrate this ? This would be most hopeful cheers, Rob 'Go Get Integrated - ride the Camel! - http://activemq.apache.org/ camel/' http://rajdavies.blogspot.com/ On Aug 23, 2007, at 9:22 AM, David Sitsky wrote: I have an application which is usin

Large PendingQueueSize values for subscriptions on a queue with one message

2007-08-23 Thread David Sitsky
I have an application which is using the latest snapshot of ActiveMQ 5.0. I have a master JVM process which sends an item to a work-item queue. I have worker JVM processes which pick up these items, process them, and possibly create new items into the work-item queue as a part of processing t