TransportListerner onCommand

Hi guys. I am using failover protocol with static discovery, along with TransportListerner for transfer/failover detection. There is an onCommand() method. I understand this method delivers transport info and on consumer side is used to count messages received. Are there some typical usage beyo

Re: delay failover transfer

Thanks Petter. I tried the configs and they work as supposed. What I am worrying is, when the main broker is down for some reason, and clients are transferring to the backup one. During the transfer, if I start the main again, the clients begin to come back to the main one. In such a case, lag cou

Journal Data Not Getting Deleted and Duplicate Messages

We are using activemq 5.7.0 and AMQPersistenceAdapter with a clean upinterval of 2000 ms (rest of the parameters are default). We are using queue configuration (no Topic). The broker service is running on Tomcat. We are injecting say around 10-30 msg per sec. What we have observed is the Data fil

JMS message listener fails intermittently when removing the message with SQL exception "No operations allowed after statement closed"

I am running ActiveMQ 5.9, Apache 7, and MySQL 5.5. I am finding that my JMS message handler is intermittently failing when it is trying to remove the message after my processing is done. It seems to be a problem with the MySQL connection, but I know the MySQL is up and right before the failure I

Re: AmqpProtocolException: Could not decode AMQP frame

Yeah I am using amqp 1.0 jms client downloaded from qpid site. The only additional information is that I have 5 threads trying to initiate consumers but each thread is creating a new connection to the active mq server and then initializing its own consumer. There is no sharing of any resources betw

broken download links on http://www.apache.org/dyn/closer.cgi/activemq/activemq-cpp/source/activemq-cpp-library-3.8.2-src.zip

The links are all broken as they go to /activemq/activemq-cpp/source/activemq-cpp-library-3.8.2-src.zip but should be /activemq/activemq-cpp/3.8.2/activemq-cpp-library-3.8.2-src.zip -- View this message in context: http://activemq.2283324.n4.nabble.com/broken-download-links-on-http-www-apache-

activemq messages not appearing in jdbc store (mysql) - how to force this

I want all my activemq messages, even the ones in the console to show up in the jdbc store, I have added the bean below and remove kahadb adapter and replaced it with the mysql adapter below, however messages do not appear in the database. I also made sure all the mysql tables were InnoDB type. Ho

Re: Messages stuck in queue

Currently we are using 5.6.0. : Setting in the server side: Consumer is AUTO_ACH, and prefetch = 100. there was not any error in the server and consumer, but there are 100 message in QUEUE, is pending, but the new message continue in and consumed by the consumers. Any fix or sett

Configuring ActiveMQ for reliability

Hi, Vi have been running ActiveMQ-5.6.0 in production since january last year and we’ve been looking to upgrade to a newer version for a while. Our main requirement is reliability and we run the broker with jdbc persistence against Oracle. However for the last few version upgrades we have attempt

Jolokia URL Path for Apache Apollo 1.7

I am using my HawtIo chrome plugin to manage the current ActiveMQ 5.9.1 by using the Jolokia path /api/jolokia. I am now evaluating Apache Apollo 1.7. I don't see the Jolokia URL listed anywhere. Can someone please let me know the URL Path? Regards, Ramki. -- View this message in context: htt

Jolokia URL Path for Apache Apollo 1.7

I am using my HawtIo chrome plugin to manage the current ActiveMQ 5.9.1 by using the Jolokia path /api/jolokia. I am now evaluating Apache Apollo 1.7. I don't see the Jolokia URL listed anywhere. Can someone please let me know the URL Path? Regards, Ramki. -- View this message in context: h

Re: AmqpProtocolException: Could not decode AMQP frame

On 05/02/2014 01:49 PM, gurilubana wrote: Does the error means that the client is sending different AMQP version message than what ActiveMQ can understand. My understanding is that ActiveMQ only supports AMQP 1.0. -- View this message in context: http://activemq.2283324.n4.nabble.com/AmqpPr

JMeter test ends with "ERROR - jmeter.protocol.jms.client.ReceiveSubscriber: The connection is already closed"

Hi, in a very simple jmeter (single thread, one loop) test I do try to receive a message with a JMS Subscriber sampler for only one sample. The tests fails due to '2014/05/05 15:38:19 ERROR - jmeter.protocol.jms.client.ReceiveSubscriber: The connection is already closed.' What is the meaning of

Re: PageFile is not loaded when recreating queue

Hi, I have logged a JIRA request for this issue. https://issues.apache.org/jira/browse/AMQ-5172 Let me know if something else is required from my side. Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/PageFile-is-not-loaded-when-recreating-queue-tp4679066