On Wed, Nov 25, 2009 at 8:19 AM, moreno9000 wrote:
>
> Now everything works!
> Thank you Gary (and bsnyder too) !
>
> This was the final configuration.
>
> Client Side
> --
> In java code I use ActiveMQConnectionFactory
> (previously, I used "generic" JMS ConnectionFactory) in order
> to c
Now everything works!
Thank you Gary (and bsnyder too) !
This was the final configuration.
Client Side
--
In java code I use ActiveMQConnectionFactory
(previously, I used "generic" JMS ConnectionFactory) in order
to call connectionFactory.setAlwaysSyncSend(true) method.
In jndi.propert
so using sync send (alwaysSyncSend=true) on the connection factory, and
Usage.sendFailIfNoSpace in your config is what you need here. This should
work and should be deterministic. If this is not the case, can you open a
jira issue and attach your test case and we can get to the bottom of this.
When
Yes, it's like producer flow control.
In 5.3 I tried to use prod.f.c. but client side
I received an exception only using an async listener
(what I need is a sync notification when queue is full).
Your last sentence ("You'll need to do much more
than just a BrokerFilter to achieve this behavior"
On Tue, Nov 24, 2009 at 3:16 AM, moreno9000 wrote:
>
> Yes,
> I want to discard sent messages if number of pending messages
> exceed a predefined limit.
> The reasons for this choice are:
>
> AMQ side: I'd like to prevent problems due to a queue with
> a high number of pending messages. In 5.1 rel
I misunderstood.
I don't know when (surely, not this week) but I promise to apply
my little test (a Producer that sends thousands of msg to a
queue with a memoryLimit expressed) to 5.4 SNAPSHOT.
I'll post a new thread with results (in both case: deterministic
or not deterministic behaviour)
Mo
On Tue, Nov 24, 2009 at 3:06 AM, moreno9000 wrote:
>
> I can't switch to 5.4-SNAPSHOT cause we (we=company where I work)
> are in production.
> The choice is between 5.1 AMQ version (the one used till now) and the
> latest stable AMQ release (5.3).
> Sorry.
Gary is asking if it's possible for you
Yes,
I want to discard sent messages if number of pending messages
exceed a predefined limit.
The reasons for this choice are:
AMQ side: I'd like to prevent problems due to a queue with
a high number of pending messages. In 5.1 release I saw that
consumers stop receving messages from a queue with
I can't switch to 5.4-SNAPSHOT cause we (we=company where I work)
are in production.
The choice is between 5.1 AMQ version (the one used till now) and the
latest stable AMQ release (5.3).
Sorry.
Gary Tully wrote:
>
> Re: deterministic memory usage, could you try a 5.4-SNAPSHOT. Usage should
>
On Mon, Nov 23, 2009 at 8:48 AM, moreno9000 wrote:
>
> Yes,
> when a procuder calls send() method, I'd like to intercept
> the request, verify number of messages in destination queue,
> throw an exception if number of msg, after this last send(),
> exceed a predefined limit.
Does this mean that y
Re: deterministic memory usage, could you try a 5.4-SNAPSHOT. Usage should
be deterministic in your case. If the behavior persists with a current
snapshot, could you raise a jira issue and attach your test case. thanks?
2009/11/23 moreno9000
>
> Yes,
> when a procuder calls send() method, I'd li
Yes,
when a procuder calls send() method, I'd like to intercept
the request, verify number of messages in destination queue,
throw an exception if number of msg, after this last send(),
exceed a predefined limit.
In AMQ 5.3 I can define a memoryLimit for a queue but
there are two "problems".
1)
Yes,
when a procuder calls send() method, I'd like to intercept
the request, verify number of messages in destination queue,
throw an exception if number of msg, after this last send(),
exceed a predefined limit.
In AMQ 5.3 I can define a memoryLimit for a queue but
there are two "problems".
1)
On Mon, Nov 23, 2009 at 8:02 AM, moreno9000 wrote:
>
> Thank you, Bruce.
>
> For my control (number of messages in a queue)
> do I need to override a specific method?
>
> Which one?
>
> send() method?
So you're trying to control the number of messages in a queue at any
given time. Are you trying
Thank you, Bruce.
For my control (number of messages in a queue)
do I need to override a specific method?
Which one?
send() method?
Thanks again,
Moreno
bsnyder wrote:
>
> On Mon, Nov 23, 2009 at 7:15 AM, moreno9000
> wrote:
>
> You already registered your BrokerPlugin via the ActiveMQ X
On Mon, Nov 23, 2009 at 7:15 AM, moreno9000 wrote:
>
> Hi,
> I'd like to write an interceptor that controls the size of a queue
> (number of messages in the queue) and throws an exception
> if the queue has reached a predefined limit.
>
> I wrote two classes.
> The first one (ItlPlugin class) impl
16 matches
Mail list logo
