A consumer has same clientid with broker

I'm using ActiveMQ 5.12.1. I start a activemq broker with default configuration on server, and there are no other processes. I find there are 2 consumers which have same clientid with broker on a queue, and the queue has many messages. These two consumers consume the queue normally. Once the n

Re: Non blocking interceptor for MQTT

Hi, I tried your suggestion. It works. I run a separate thread which continuously removes messages from the queue and does the processing. However, the problem is I get the below exception when I close the broker. javax.jms.JMSException: AMQ119016: Connection failure detected. Unblocking a bloc

message transformer missing

is there a message transformer available, which transforms object messages to xml (or json)? the transformer mentioned in this article Message Transformation : org.apache.activemq.util.oxm.XStreamMessageTransformer

ActiveMQ : The session has already been closed

Hi All, I am facing some issue with mq version is 5.12 with PooledConnectionFactory. I am using spring jms to produce and consume data form active mq. Execution of JMS message listener failed, and no ErrorHandler has been set.","logger_name":"org.springframework.jms.listener.DefaultMessageListene

Re: Consumer is not getting all messages from ActiveMQ

Ravi Rapolu recently posted a very similar question; it's possible that there's a bug. It's also possible that you're doing something that causes this in your code; the most obvious possibility is if you're using CLIENT_ACKNOWLEDGE mode (the default) and your consumer code has a path where it can

Re: Durable Subscribers going offline - Deadlock - Network Of Brokers

1. What tells you that the three threads at the bottom are deadlocked? Usually I'd expect to see that those threads were holding locks that the other threads were waiting to acquire. 2. When you see the javax.jms.InvalidClientIDException, which broker (hub master, hub slave, or spoke) do you see

Plan Khe pen

Reddit.com new new new

Configuring HSQLDB as Message Store

Is there any example of how to configure ActiveMQ to use HSQLDB as message store? What does means "support" on this page: http://activemq.apache.org/jdbc-support.html Does it means that we don't need to install HSQLDB? Or the DB-driver is included? Thanks in advance. -- View this message in c