Thank you for your answer. This would be explained why consumers didn't get a
message when all messages are prefetched by other consumers.
Suppose we have 21.000 messages. The prefect limit is set to 1000 (default
value). One consumer consumes some of the messages. Then it stops and leaves
the co
It's a single browser window, no tabs.
There are application windows open inside the browser window (telnet, chat),
but they are all using the
single AMQ connection established when application was started.
Phil
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-
On Feb 9, 2011, at 11:00 AM, patrice wrote:
> but, it does not work. I traced request, there are send from the web page,
> but nothing is updated,...
> looking at log file I can see the following error
>
> java.lang.IllegalStateException: !(Jetty || Servlet 3.0 ||
> ContinuationFilter)
>
> org
On Feb 8, 2011, at 4:13 PM, habumaster wrote:
>
> Also seeing Gets receiving responses but continuing to spin, even though
> another Get is spawned.
> They start piling up and browser gets busy with all the Gets...
So your browser has multiple polls (GETs) underway at the same time? Are a
unacked prefetched messages are only available to other consumers when
a consumer dies. If the connection is not closed, from the broker
perspective, the consumer is just slow.
You need to decrease the inactivity timeout (default 30 seconds) on
the interrupted consumers connection such that the bro
We encountered a strange behavior if we change the prefetch size for the
consumers. We have two threads that receives message. The first one fetch
some messages and is then interrupted without closing the connection to the
broker. If the second thread is created it can't receive any messages. In
t
the unit tests are full of programmatic usage, have a peek at the
various packages in the source:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/
On 9 February 2011 03:29, Jim Newsham wrote:
>
> We're creating an embedded broker service programmatic
Hi,
yes. This is not currently supported.
Regards
--
Dejan Bosanac
-
FuseSource - The experts in open source integration and messaging.
Email: dej...@fusesource.com
Web: http://fusesource.com
Twitter: http://twitter.com/dejanb
ActiveMQ in Action - http://www.manning.com/snyder/
Hi,
this looks good. Tmp files will be stored at broker-data-dit/tmp-storage
Regards
--
Dejan Bosanac
-
FuseSource - The experts in open source integration and messaging.
Email: dej...@fusesource.com
Web: http://fusesource.com
Twitter: http://twitter.com/dejanb
ActiveMQ in Actio
