Some messages sent to Topics are Lost

[daltonch <ch...@2kgt.com>]

I have a pretty simple setup. I have 1 Queue that a java application post a
message on. I have a Listener on that queue which takes the message and post
it to a Topic (does some stuff to it first). I then have several topic
listeners configured, each one does something different with the message.
Sometimes the message is never picked up by the Topic Listeners. The
application that copies the message from the Queue to the Topic is the same
process so there is not the issue of it not running. The frustrating part is
I can startup the listeners, post some messages and they all make it to the
Topic, then 5 minutes later I can post some messages and half of them make
it, then 5 minutes later they will all make it. This is causing me to loose
many messages and I have no idea where they are going. In the JMSAdmin
console the Message Enqueued counter is incremented correctly with the
number of messages sent to the topic but the Message Dequeued is always
lower, exactly by the number of messages that I am losing.



--
View this message in context: http://activemq.2283324.n4.nabble.com/Some-messages-sent-to-Topics-are-Lost-tp4682262.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Some messages sent to Topics are Lost

[Jim Gomes <e....@gmail.com>]

Check your clocks. They may be out of sync, and the messages may become
stale and be ignored by a consumer.  To test this, you can run the broker
and client on the same machine.  If that is not possible, add the
TimestampPlugin to your broker.  In NMS (I know you are using the Java
client), there is a *consumer.nms.ignoreExpiration=true* parameter that can
be added to the consumer topic destination that will consume "expired"
messages. This is useful to work around clock synchronization problems.



On Wed, Jun 18, 2014 at 8:58 AM, daltonch <ch...@2kgt.com> wrote:

> I have a pretty simple setup. I have 1 Queue that a java application post a
> message on. I have a Listener on that queue which takes the message and
> post
> it to a Topic (does some stuff to it first). I then have several topic
> listeners configured, each one does something different with the message.
> Sometimes the message is never picked up by the Topic Listeners. The
> application that copies the message from the Queue to the Topic is the same
> process so there is not the issue of it not running. The frustrating part
> is
> I can startup the listeners, post some messages and they all make it to the
> Topic, then 5 minutes later I can post some messages and half of them make
> it, then 5 minutes later they will all make it. This is causing me to loose
> many messages and I have no idea where they are going. In the JMSAdmin
> console the Message Enqueued counter is incremented correctly with the
> number of messages sent to the topic but the Message Dequeued is always
> lower, exactly by the number of messages that I am losing.
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/Some-messages-sent-to-Topics-are-Lost-tp4682262.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>