Forcing queue flush through to consumers/browsers?

[rxg <ro...@yahoo.co.uk>]

Hi all,
I am looking to replace a system of file exchange between two of our systems
with a system based on JMS, the idea being the following:
1) System A writes a small number of medium- and large-sized events to a
Queue over a period of time (let's say several hundred of the order of 4K
per message, with a few biggies of 4M, all over 2 hours)
2) System B periodically snapshots the queue, consumes all available
messages and writes OK or NOT_OK messages to a different queue for
consumption by the upstream system
3) System A has a consumer thread that is blocks on receive() until there
are OK or NOT_OK messages to be consumed

However, while I can get a trivial example to work fine, attempts to test
anything beyond a toy set-up have not been fruitful.  Examples of problems
that I've had:
a) System B sees no messages with receiveNoWait while there have been
several sitting in the queue for an hour - fixed by using prefetch=0 in the
consumer
b) Problems writing large messages to the same queue that I'm consuming from
(in the same thread) - fixed by disabling flow control
c) prefetch=0 causes QueueBrowser to hang AMQ-2171
d) QueueBrowser only shows the first 20 or so messages in the queue (with
prefetch != 0), while there may be several hundred AMQ-2172

I've been checking out ActiveMQ (standalone config) for the last week or so
and at this point I feel that either I'm missing something, or I'm trying to
do something that it wasn't designed for - or both!  Should I keep
persisting - and filing bugs ;) - or have I misunderstood some core
functionality?

The frustrating thing is that writing messages to the queue seems to be
mostly OK (apart from problem b above), since I can easily see the desired
messages in the desired queues with the web console.  It's just that my
system B doesn't seem to see the same thing as the web console!  Am I
somehow missing a magic "write-through-to-clients" setting in the broker? 
(I have seen the doc on async write, flow control and prefetch, but maybe
there are other knobs to twiddle?)

Thanks for any pointers you can give,
Robert
-- 
View this message in context: http://www.nabble.com/Forcing-queue-flush-through-to-consumers-browsers--tp22621755p22621755.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.