activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dbczak <...@dbconcert.com>
Subject Duplicate Messages on Listener Restart
Date Mon, 14 Sep 2009 18:25:53 GMT

Hi,

I have a message client that produces a message and sends to multiple
listeners by using the URL:
fanout:(static:(tcp://host1:61616,tcp://host2:61616,tcp://host3:61616
...))?fanOutQueues=true&minAckCount=1 

I'm getting duplicate messages whenever any of the listener is shut down and
restarted but the sender is not.  For example:

I start 2 listeners.
I run the sender which sends one message - both listeners receive and
acknowledge.
I shut down one of the listeners.
The sender then sends another message which only reaches one of the
listeners.
I bring the listener that is down back up.  - At this point, this listener
receives both the first message that it already processed and the new
message it missed.  It should only receive the one it missed, but I can't
stop the other one from coming in too.

The code for both the listener (TIPServer.java) and sender (TIPClient.java) 
are attached.  

http://www.nabble.com/file/p25440673/TIPServer.java TIPServer.java 

http://www.nabble.com/file/p25440673/TIPClient.java TIPClient.java 
-- 
View this message in context: http://www.nabble.com/Duplicate-Messages-on-Listener-Restart-tp25440673p25440673.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message