I think it might be because of this flow control message that I see between
brokers. Here pprfdaa300 is another broker. But why would this happen
between brokers though?
2013-01-03 14:44:21,587 | INFO |
Usage(default:memory:queue://eventsEndpoint:memory) percentUsage=0%,
usage=0, limit=20971520,
Just one more question, is there a way to force acknowledgment of a message
or send it to DLQ? I am wondering what safeguards we can put in place in
active mq so that if and when this occurs it doesn't impact all other
clients.
On Thu, Jan 3, 2013 at 7:57 AM, Mohit Anchlia wrote:
> Yes it's reall
Can you post the config for the two brokers?
On Thu, Jan 3, 2013 at 3:35 PM, Mohit Anchlia wrote:
> It's A <> B
>
> Broker A has 2 messages but no consumers
> Broker B has consumers but don't get messages forwarded
>
> On Thu, Jan 3, 2013 at 1:33 PM, Christian Posta
> wrote:
>
> > Can you ex
It's A <> B
Broker A has 2 messages but no consumers
Broker B has consumers but don't get messages forwarded
On Thu, Jan 3, 2013 at 1:33 PM, Christian Posta
wrote:
> Can you explain how the brokers are set up? A ---> B ? and which has the
> messages and which has the consumer?
>
>
> On Thu,
Can you explain how the brokers are set up? A ---> B ? and which has the
messages and which has the consumer?
On Thu, Jan 3, 2013 at 2:19 PM, Mohit Anchlia wrote:
> As I understand that if I have network of brokers than the messages will be
> sent to the broker that has active consumers on it. I
I get this log entry sometimes in my ActiveMQ client program. It's being
logged by the ActiveMQ .NET client.
ERROR 2013-01-03 06:01:27.8351 | ActiveMqInternal | Thread ID: 40 | Service
Key: | Service ID:
Message: Connection[ID:S601870AT1VW29-54468-634893106755963289-1:0]: No such
consumer active
that factory is plugable, so you could extend
ConditionalNetworkBridgeFilterFactory
with your own limiter implementation.
It can be specified via a bean in the xml configuration for a network
connector.
It would make a nice patch to add that option :-)
in any event please raise an enhancement reque
Yep, that's correct. It's a messages/second.
Let me give it a deeper look when I get a second. Apollo uses HawtDispatch
which uses transports that have an optional rate limiter like the one
you're looking for, so I wonder if somethings similar can be done for
ActiveMQ.
On Thu, Jan 3, 2013 at 9:35
I'm currently using ActiveMQ-5.5.1. The
ConditionalNetworkBridgeFilterFactory was first implemented in 5.6.0 so I
would have to upgrade to get this factory. Second, the setRateLimit method
looks like the units are in MESSAGES/duration and not bytes/duration.
--
View this message in context:
h
Yes it's really helpful. Thanks again
On Thu, Jan 3, 2013 at 5:33 AM, Christian Posta
wrote:
> Good call Claus. I've updated the wiki page here:
>
> http://activemq.apache.org/how-do-i-find-the-size-of-a-queue.html
>
> Should be a couple hours to propagate through.
>
> Thanks!
>
>
> On Thu, Jan 3
Do you know what the units are for setRateLimit(int rateLimit)? The test
code you showed me looks like the units are in messages and that will not
work for me because I am sending just one message (file) that is huge - it
is a TIFF file. I need the rate units to be something like bytes per
second
I am looking into AMQ groups and have a question regarding closing a group.
Here is my general setup:
I push a message with a group ID onto a queue. A separate process picks up
the message and reports the message text and group ID to stdout (it's just a
sandbox process). That process then sends a
Check out this test case around line 303:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerQueueClientsReconnectTest.java?view=markup
On Thu, Jan 3, 2013 at 7:23 AM, billy wrote:
> I read about that too and it sounds like it will work
Good call Claus. I've updated the wiki page here:
http://activemq.apache.org/how-do-i-find-the-size-of-a-queue.html
Should be a couple hours to propagate through.
Thanks!
On Thu, Jan 3, 2013 at 1:05 AM, Claus Ibsen wrote:
> On Wed, Jan 2, 2013 at 9:33 PM, Christian Posta
> wrote:
> > Enqueu
use the default (store) cursor. It will just buffer messages up to 70% of
the memory limit so there is no need to block.
On 2 January 2013 18:43, xawiers wrote:
> Anyway. Tested with 5.7.0 and 5.5.1:
> if define vmcursor and lower memoryUsage (limit 64mb)
> then memory fills up adding more and
On Wed, Jan 2, 2013 at 9:33 PM, Christian Posta
wrote:
> Enqueue count = number of messages sent to the queue
> Dequeue count = number of messages ack'd by the consumer
> Inflight count = number of messages sent to consumer's session (and are not
> ack'd by consumer)
> Dispatch count = messages se
16 matches
Mail list logo
