Hi all,
is it possible to get the ID of Connection used by a producer
(java application) using MBean API?
I didn't find code examples :-(
Many thanks id advance
Moreno
--
View this message in context:
http://old.nabble.com/MBean-connection-ID-tp27259868p27259868.html
Sent from the ActiveMQ
ngs
aren't connected?
Thanks
Moreno
rajdavies wrote:
>
> that'll be the jmx implementation - which is part of the JRE - can you
> run with out jmx ?
>
> On 19 Jan 2010, at 16:25, moreno9000 wrote:
>
>>
>> Hi rajdavies,
>> I see a lot of threads
u take a stack trace of the broker ? - the threads should be
> getting garbage collected
>
> thanks,
>
> Rob
> On 19 Jan 2010, at 10:37, moreno9000 wrote:
>
>>
>> I confirm Marcin's problem (with AMQ 5.3).
>>
>> One producer (java application
I confirm Marcin's problem (with AMQ 5.3).
One producer (java application with transport=openwire)
For each message producer open a Connection, send a msg, close the
Connection.
Server side no problem for what concern file descriptors opened,
memory usage, socket opened (with netstat I see all 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
e this behavior")
sounds worrying :-(
bsnyder wrote:
>
> On Tue, Nov 24, 2009 at 3:16 AM, moreno9000
> wrote:
>>
>
>> Client side: I'd like to raise an exception to producer in order
>> to say it "Please, stop sending messages till messages are read
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
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
sage 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
>
>
--
View this message in context:
http://old.nabble.com/How-to-%22activate%22-an-in
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)
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 v
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) implements BrokerPlugin.
The second one (ItlBroker class) extends Brok
Is my issue similar to this one?
https://issues.apache.org/activemq/browse/AMQ-1022 AMQ-1022
In 1022, error was due to a "permission (to write on a queue) problem",
in my case error is due to a "queue full problem",
but in both cases producer receives an exception only in an asynchronous way
(
Thank you Brett,
but I turned off async send, according to Gary Tully's first suggestion
(actually Producer's send speed decresead).
The "strange" matter is that Producer sends sync, but it receives
exception (when queue is full) only via an exception listener.
I don't know if is a AMQ's bug or,
Yes, exception listener receives a notification when queue is full!
Is this the only way to get a send error?
(Perhaps I'm wrong, but I think that is much more simple to manage an
exception
in the thread that exec send() instead of delegating this management
to exception listener's threads).
Now AMQ doesn't use tmp_storage but there isn't
any change for what concerne Producer exception :-(
Gary Tully wrote:
>
> last piece is to configure a pendingQueuePolicy for your queue that will
> cursor messages in memory rather than spool out to a store. The default is
> a
> store cursor wh
it defaults to
> async
> sending for non persistent or non transactional messages) so that you can
> catch any exception.
>
>
> 2009/10/28 moreno9000
>
>>
>> Hi all,
>> I'm using AMQ 5.3 with a Producer that sends 10.000 very small msg
>> (1kb for m
Hi all,
I'm using AMQ 5.3 with a Producer that sends 10.000 very small msg
(1kb for msg, no persistence) to a queue.
No consumers are listening to the queue.
In activemq.xml this is System Usage configuration:
rajdavies wrote:
>
>
>
> On 28 Jul 2009, at 10:35, moreno9000 wrote:
>
>>
>> Hi all,
>> I have a Producer that sends 250 messages to QUEUE_01.
>> Messages expire after 30 seconds.
>> AMQ 5.2 is configured to use Discarding DLQ Broker Plugin.
>&g
rajdavies wrote:
>
>
>
> On 28 Jul 2009, at 10:35, moreno9000 wrote:
>
>>
>> Hi all,
>> I have a Producer that sends 250 messages to QUEUE_01.
>> Messages expire after 30 seconds.
>> AMQ 5.2 is configured to use Discarding DLQ Broker Plugin.
>&g
Hi all,
I have a Producer that sends 250 messages to QUEUE_01.
Messages expire after 30 seconds.
AMQ 5.2 is configured to use Discarding DLQ Broker Plugin.
After 30 seconds I expect messages to be sent to DLQueue
and immediately discarded.
This doesn't happen :-(
More exactly, it happens only wh
22 matches
Mail list logo
