Re: ActiveMQ.Advisory.MessageDiscarded.Queue

2015-10-09 Thread Tim Bain
I believe that the discarded message count in JMX is incremented (and so I'd expect an advisory message to be generated, though I've never looked for one to confirm that) when a message expires while still on the broker. (I believe I've observed that if the message expires after being dispatched to

Jmeter testing with activeMQ version 5

2015-10-09 Thread bappelt
I am trying to do some Jmeter performance testing of activeMQ as described here: http://activemq.apache.org/jmeter-performance-tests.html However, all the activemq-jmeter-*.zip distributions linked there are for version 4 and earlier. Are these tests not available for more recent version of activ

Re: ActiveMQ consumer count is set to "0"

2015-10-09 Thread dhananjay.patkar
I am able to reproduce this issue by restarting the broker, when camel consumers are sending those millions of messages on the queue. I am planning to set recoveryInterval on the camel JmsConfiguration, please post your views on this. -- View this message in context: http://activemq.2283324.n4

Composite destinations and client support

2015-10-09 Thread Basmajian, Raffi
Are composite destinations supported for all types of clients, not just JMS/Java? For example, is it possible for HTTP client to send a message to three queues at once? curl -d "body=message" http://mqhost/api/message/TEST1,TEST2,TEST3?type=queue This e-mail transmission may contain informati

Re: Program blocking waiting for a lock

2015-10-09 Thread spamtrap
On Fri, 9 Oct 2015 11:03:10 -0400, Timothy Bish wrote: >On 10/09/2015 10:56 AM, spamtrap wrote: >> On Fri, 9 Oct 2015 10:49:51 -0400, Timothy Bish >> wrote: >> >>> On 10/09/2015 10:37 AM, spamtrap wrote: On Mon, 21 Sep 2015 15:34:17 +0100, spamtrap wrote: > ActiveMQ-CPP 3.9.0

Re: Program blocking waiting for a lock

2015-10-09 Thread Timothy Bish
On 10/09/2015 10:56 AM, spamtrap wrote: > On Fri, 9 Oct 2015 10:49:51 -0400, Timothy Bish > wrote: > >> On 10/09/2015 10:37 AM, spamtrap wrote: >>> On Mon, 21 Sep 2015 15:34:17 +0100, spamtrap >>> wrote: >>> ActiveMQ-CPP 3.9.0 A program is blocking waiting for a lock: #0

Re: Program blocking waiting for a lock

2015-10-09 Thread spamtrap
On Fri, 9 Oct 2015 10:49:51 -0400, Timothy Bish wrote: >On 10/09/2015 10:37 AM, spamtrap wrote: >> On Mon, 21 Sep 2015 15:34:17 +0100, spamtrap >> wrote: >> >>> ActiveMQ-CPP 3.9.0 >>> >>> A program is blocking waiting for a lock: >>> >>> #0 0x00367980b5bc in pthread_cond_wait@@GLIBC_2.3.2 (

Re: Program blocking waiting for a lock

2015-10-09 Thread Timothy Bish
On 10/09/2015 10:37 AM, spamtrap wrote: > On Mon, 21 Sep 2015 15:34:17 +0100, spamtrap > wrote: > >> ActiveMQ-CPP 3.9.0 >> >> A program is blocking waiting for a lock: >> >> #0 0x00367980b5bc in pthread_cond_wait@@GLIBC_2.3.2 () >> from /lib64/libpthread.so.0 >> #1 0x7fcab6c6c006 in (a

Re: Program blocking waiting for a lock

2015-10-09 Thread spamtrap
On Mon, 21 Sep 2015 15:34:17 +0100, spamtrap wrote: >ActiveMQ-CPP 3.9.0 > >A program is blocking waiting for a lock: > >#0 0x00367980b5bc in pthread_cond_wait@@GLIBC_2.3.2 () > from /lib64/libpthread.so.0 >#1 0x7fcab6c6c006 in (anonymous namespace)::doMonitorEnter ( >monitor=0x26f

Re: need advice for single queue configuration

2015-10-09 Thread Leonardo K. Shikida
Hi Andy I think I am trying to use activeMQ as the workmanager here. My consumers are MDBs, so I can control the pool size via tomee.xml and the transactional nature of JMS is exactly what I was counting with. If a message delivery fails, then it automatically returns to the queue (because it's wa

Re: need advice for single queue configuration

2015-10-09 Thread agumbre...@tomitribe.com
Ouch, I'll try and point you in a better direction. A message consumer should never block longer than at maximum a few seconds, else you are going to starve the pool in no time. You should only be checking that the message payload is valid. If you need a long running task then hand the message o

Message disappears after JMX-retry on DLQ when processing fails for a second time

2015-10-09 Thread boriss
I'm using the latest AMQ-5.12.0, trying to recover messages which failed enough times to be moved to the DLQ. Invoking the retryMessage(messageId) and retryMessages() operations from JMX results that if the consumer fails again to consume, the message disappears completely and is being lost. I sa

Re: ActiveMQ consumer count is set to "0"

2015-10-09 Thread dhananjay.patkar
We are using ActiveMQ 5.10 broker with following configuration JVM heap 48G out of which 70% allocated for memoryUsage 70G storage and 1G for temp we are using Apache camel 2.10.2 route to consume messages from queue. After receiving message, we create ~40k smaller messages/ received message and

ActiveMQ.Advisory.MessageDiscarded.Queue

2015-10-09 Thread fengcanyue
advisory code: Destination destination =session.createQueue("test"); Destination advisoryDestination = AdvisorySupport.getMessageDiscardedAdvisoryTopic(destination); MessageConsumer consumer = session.createConsumer(advisoryDestination); consumer.setMessageListener(new MessageListen

Re: need advice for single queue configuration

2015-10-09 Thread Tim Bain
If you want redelivery to other consumers rather than just the one to which the message was first delivered (which is how I interpreted your paragraph about message-driven beans) and you can live with out-of-order delivery, I'd think you'd want to configure broker redelivery as described at the bot

Re: ActiveMQ password encryption Error

2015-10-09 Thread Tim Bain
When you restarted the broker after reconfiguring it, did you remember to set the environment variable to the new encryption password? On Oct 8, 2015 8:36 AM, "rosy.sal...@murex.com" wrote: > I'm using activemq 5.11.1. I applied password encryption using the > following > url: http://activemq.apa

Re: Activemq-cpp Synchronous Receive from Multiple Consumers

2015-10-09 Thread Tim Bain
Do you have a procedure that will reliably reproduce both problems you describe (negative consumer counts and non-delivery of messages) each time you run it? Have you used a JMX viewer such as JConsole to examine the subscriptions on each destination both when the broker is in a good state and whe