When broker has one publisher and subscriber (via MQTT) there are no messages
in persistance. I tested in LevelDB and MySQL. In LevelDB was only topics
name. Maybe configuration was wrong or I need another persistance? Maybe
MQTT messages not writes to message storage?
My task is intercept
Some further info
If I stop the standalone activemq broker/instance and look at the message in
the queue on the side of the embedded broker, I can see the message has the
correct expiration set:
When I start the standalone broker, this message gets routed to the topic
with the following
On 01/22/2014 10:52 PM, Li Li wrote:
I found the problem. I have only 160 messages and all are dispatched
to a single worker.
how to avoid this?
You need to set the consumer prefetch.
http://activemq.apache.org/what-is-the-prefetch-limit-for.html
On Thu, Jan 23, 2014 at 11:27 AM, Li Li
try it out in a debugger :)
afaik, it will be all the mbeans
On Wed, Jan 22, 2014 at 11:20 PM, khandelwalanuj
khandelwal.anu...@gmail.com wrote:
Hi,
According to my understanding:
When I run *activemq-admin query --view InactiveDurableTopicSubscribers
--jmxurl
I have also tried replacing the 'preserveMessageQos=true' config option (on
the camel routes/subscriptions) with 'disableTimeToLive=true' option,ie
This seems to have no effect on the message expiration either - it is still
being set. The only messages I can see with an expiration of 0 are those
On 01/22/2014 10:41 PM, HellKnight wrote:
I want to set a unique guid for each message in message head , then if I want
, I could delete a specific message if I want to. Is there any api in NMS
could help me deleting the message ? I am using ActiveMQ 5.9.0 and NMS 1.6.1
Thanks in advance.
--
Hi to all,
I'm not very satisfy by documentation that is fournished with activeMq-CMS
project, to understand how I can do with a Queue and Topic. I well know what
happen when I use a queue...but I don't know what happen when I use a TOPIC.
I need a clear explaination and some examples, tipical
On 01/23/2014 11:14 AM, cecchinoSMI wrote:
Hi to all,
I'm not very satisfy by documentation that is fournished with activeMq-CMS
project, to understand how I can do with a Queue and Topic. I well know what
happen when I use a queue...but I don't know what happen when I use a TOPIC.
I need a
I am wondering if there is an advantage to having ActiveMQ installed on a
Physical server over a VM, or vice versa. Thoughts?
Ok this is the documentation
but how I specified in the message above, I need some examples (code) and I
need an explanation to monitoring a Topic in my localhost.
--
View this message in context:
Ok, so after some discussion with the Karaf folk, this looks like it's
related to an existing issue
(https://issues.apache.org/jira/browse/AMQ-4850). It looks like the
activemq-web-console bundle's headers export all the activemq packages
but doesn't get wired up to all the necessary
No more advantage than for any other application/service. There's nothing
inherit to ActiveMQ that needs real hardware - it relies entirely on the O/S
to handle low-level hardware I/O.
--
View this message in context:
I have update ActiveMQ from 5.6.0 to 5.9.0 on a Ubuntu 12.04 64bit.
After a few days the activemq get out of memory. If I send 1000 of Messages
in a Testcase the memory do not increase.
If have a heapdump before the activemq get out of memory:
heapdump-1390484948363.zip
We fixed the problem by moving activemq to the new server, and having
everything connect to it as the broker instead of the other way around.
Thanks very much for your help, very appreciated.
--
View this message in context:
Is the stand-alone broker using the TimeStampingBrokerPlugin?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Persistent-messages-moving-to-DLQ-when-consumer-not-active-tp4676652p4676718.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Thanks for the reply. I think your solution will delete all the message from
a queue when there is no active consumer. But I want to delete messages
according to their unique ID (the ID is set by me ) , and I want to delete
messages when there are active consumers. Is there a simple solution for
On 01/23/2014 09:27 PM, HellKnight wrote:
Thanks for the reply. I think your solution will delete all the message from
a queue when there is no active consumer. But I want to delete messages
according to their unique ID (the ID is set by me ) , and I want to delete
messages when there are active
I read a related post at stackoverflow.com , and you said IKVM could help in
this situation ,I want to write a java program that could delete specific
message as I wanted and then convert it to a dll by IKVM ,do you think this
solution worth trying ?
--
View this message in context:
Sure thing - glad you got it solved!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Connection-being-made-but-not-registering-as-a-Consumer-of-any-queues-tp4676052p4676724.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Could there be clients creating temporary destinations and never deleting
them?
Temporary destinations are automatically removed on shutdown of the session
which created them (or the connection of that session). Before then, they
will live indefinitely unless the delete() method is explicitly
An embedded broker is a broker in the same JVM process.
It's not possible for the code posted to give connection counts for a broker
in another JVM as the code is walking the internal data structures of the
broker, which are only accessible from the same JVM (unless some debugging
magic is also
Is the embedded broker looking for messages on the Topic?
Keep in mind messages sent to a Topic are only ever dispatched to either
active subscriptions, or durable subscriptions. In fact, the broker never
stores messages for a Topic, but instead stores them in the Topic
subscriptions, which
22 matches
Mail list logo
