On Mon, Sep 14, 2009 at 12:25 PM, dbczak <z...@dbconcert.com> wrote: > > 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
What behavior are you expecting by using the fanout transport and the fanOutQueues=true transport option? Please make sure to read everything on the following page regarding the fanout transport: http://activemq.apache.org/fanout-transport-reference.html Bruce -- perl -e 'print unpack("u30","D0G)u8...@4vyy9&5R\"F)R=6-E+G-N>61E<D\!G;6%I;\"YC;VT*" );' ActiveMQ in Action: http://bit.ly/2je6cQ Blog: http://bruceblog.org/ Twitter: http://twitter.com/brucesnyder
