Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of bruce.snyder@gmail.com
 designates 209.85.220.220 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=glpc/od14J9v8MsbF8SLrr+G6/PxzWBwCTryBnHSvDDblFf1IhZdgSjFvNRMOKK47Z
         e8cjt0vtBj2k1lcp/T0VDsuvZBP32qCay7MTfMHFmMsEyP57B8h5/L5f9cqnKCFS38bU
         67bNW+i7PAG7afJQZ3lVk8PL5vt7gziBI6yC8=
MIME-Version: 1.0
In-Reply-To: <25440673.post@talk.nabble.com>
References: <25440673.post@talk.nabble.com>
Date: Mon, 14 Sep 2009 21:15:04 -0600
Message-ID: <7b3355cb0909142015g56802671q429a0e98bbf2562@mail.gmail.com>
Subject: Re: Duplicate Messages on Listener Restart
From: Bruce Snyder <bruce.snyder@gmail.com>
To: users@activemq.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

On Mon, Sep 14, 2009 at 12:25 PM, dbczak <zak@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=3Dtrue&minAckCount=3D1
>
> I'm getting duplicate messages whenever any of the listener is shut down =
and
> restarted but the sender is not. =A0For 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. =A0- At this point, this liste=
ner
> receives both the first message that it already processed and the new
> message it missed. =A0It 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.jav=
a)
> 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=3Dtrue 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
--=20
perl -e 'print unpack("u30","D0G)U8V4\@4VYY9&5R\"F)R=3D6-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