Category : activemq

I am using INDIVIDUAL_ACKNOWLEDGE mode to receive messages and manually acknowledge messages received from AMQ using C++ CMS library which implements JMS standards via Openwire protocol. I have got two consumers (Consumer 1, Consumer 2) receiving from same queue. When Consumer1 gets the message, Consumer ACKs the message. When I kill Consumer 1, Consumer 2 ..

Read more

I am using ActiveMQ 5.10.2 and I am trying to test a failover scenario with C++ clients using Apache ActiveMQ CMS (activemq-cpp-library-3.9.5). The configuration for one of the two brokers is: <broker xmlns="http://activemq.apache.org/schema/core" brokerName="broker-1" dataDirectory="${activemq.data}" useJmx="true"> <managementContext> <managementContext createConnector="true" connectorPort="1099"/> </managementContext> <persistenceAdapter> <kahaDB directory="${activemq.data}/kahadb"/> </persistenceAdapter> <networkConnectors> <networkConnector name="broker1->broker2" uri="static:(failover:(tcp://broker-2:61637))" duplex="false" decreaseNetworkConsumerPriority="true" networkTTL="2" dynamicOnly="true"> </networkConnector> </networkConnectors> ..

Read more

We are trying to implement Active MQ C client in AIX Server. Having lot of compatibility issues to compile the CMS client in AIX. Please anyone suggest me what are other possibilities to use active MQ client and Step by step it would help to solve our issue. Server : AIX 6.1 compiler : XLC ..

Read more

I am having a lot of difficulty getting limited retries and dead letter queues to work in ActiveMQ. I am developing using the activemq-cpp library in linux. This is what I want to do: set DLQ and retry policies on the broker (xml below, schedulerSupport enabled) register a cms::MessageListener against a queue using Auto-acknowledge Have ..

Read more

How do I terminate/stop all other thread when I catch specific value in one of the thread execution (in activemq cpp)? I have parallely launched 5 threads which are calling specific function. If one of them returns some specific value, I need to terminate the further processing of all other remaining threads and the specific ..

Read more