Re: ActiveMQ slow consumer policy

Thanks - nms.prefetchPolicy.topicPrefetch=1 did the trick. I'm seeing fairly long latencies - upto about 500ms, and the broker is using over 500MB of memory. But it is managing the queues properly. gtully wrote > I had a peek that your code, the problem is on the broker. > The problem is that the

Re: ActiveMQ slow consumer policy

Thanks - nms.prefetchPolicy.topicPrefetch=1 did the trick. I'm seeing fairly long latencies when I crank up the producer rate - upto about 500ms, and the broker is using over 500MB of memory. But it is managing the queues properly. gtully wrote > I had a peek that your code, the problem is on the

[ANNOUNCE] ActiveMQ-CPP Version 3.5.0 Released

Hi Everyone, Its official, AcitveMQ-CPP v3.5.0 has now been released. This is a new Major release of ActiveMQ-CPP with several new APIs and internal changes meant to improve overall stability of the C++ client. Besides a large amount of bug fixing and memory fixing this release also features a

Re: RESTful POSTing of messages containing a correlation ID

I was able to update my C-based client to add/update the URI in HTTP start-line(first header). When the user of my client app wants to set the JMSCorrelationID header field of a message, I add a "&JMSCorrelationID=" parameter to the URI in the HTTP POST request's start-line(first header). That en

Having a problem in receiving a subscribed Message using MQTT

Hi, I am using Apache ActiveMQ 5.6. I have configured transport connectors for activemq And I am publishing a MQTT Message with "Hello" payload using Paho MQTT Client But the problem I am facing is with hierarchical topic for ex. PUBLISH TOPIC ---> abc/123/register and SUBSCRIBE TOPI

Re: Having a problem in receiving a subscribed Message using MQTT

Wildcard looks correct. I'll give it a shot on my side and see what's going on... On Friday, December 21, 2012, parimal.patel wrote: > Hi, > I am using Apache ActiveMQ 5.6. > I have configured transport connectors for activemq > > > > > > And I am publishing a MQTT Message with "Hello"

Re: Enabling Message Groups

So I kicked up the prefetch and was able to get some messages into the other consumers so I'm fairly confident that JMSXGroupID is working as designed, as I now have 5 active consumers, which makes sense given my latest message traffic. So I guess my question is say I have 100k messages on the queu