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 jlebleu@gmail.com designates
 209.85.219.216 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
         :cc:content-type:content-transfer-encoding;
        b=BuvefnidPfzvnpnsPEklA/WLnHG5uIwFiv/q572RDcx3RK+6QM2LgFIk5NZLcAFlim
         XY36DIViGl+ZKLEMBvxgbrSIaZvTyGQas2yguk8QMCK/FUQo1rcA9LWJ/OX2qkR4a1yR
         S+KpdilMCUyVvMPYk4Tb6WxxCtGJJ4SHELX/8=
MIME-Version: 1.0
In-Reply-To: <ec6e67fd1002160754r51bbb6bav5607330cc71e44a@mail.gmail.com>
References: <e870fe0e1002160738s16c7ca38kb0ef0d4b5b6bb994@mail.gmail.com>
	 <ec6e67fd1002160754r51bbb6bav5607330cc71e44a@mail.gmail.com>
Date: Tue, 16 Feb 2010 17:17:44 +0100
Message-ID: <e870fe0e1002160817x506d4aebm2a4f5ef10a57c57d@mail.gmail.com>
Subject: Re: Consumer and Failover
From: Jean-Yves LEBLEU <jlebleu@gmail.com>
To: users@activemq.apache.org
Cc: mlemabec@gmail.com
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

On Tue, Feb 16, 2010 at 4:54 PM, James Strachan
<james.strachan@gmail.com> wrote:
> On 16 February 2010 15:38, Jean-Yves LEBLEU <jlebleu@gmail.com> wrote:
>> Hi all,
>>
>> I am trying to use the failover transport
>> (failover:(tcp://localhost:61618)), and I have some questions :
>>
>> I did a test with a simple consumer in scala (see the code and log at
>> the end of the mail).
>>
>> Scenario :
>> Broker is stopped.
>> We start the consumer, it waits
>> Start the broker
>> Consumer connects and consume messages
>> Stop the broker and start the broker again
>> Consumer tries 6 times to reconnect and stop working.
>
> I wonder if you have not restarted the broker in time for the client
> to reconnect? How long does the client take to reconnect and how long
> is the broker down for?
>
> Maybe you could try increasing the amount of time the failover
> transport waits before failing to connect...
>
> http://activemq.apache.org/failover-transport-reference.html
>
> e.g. try this URL
>
> failover:(tcp://localhost:61618)?maxReconnectAttempts=3D1000
>
>
> BTW slightly more idiomatic Scala code for onMessage would be...
>
> def onMessage(message: Message): Unit =3D message match {
> =A0case textMessage: TextMessage =3D> =A0println("Message recieved: " +
> textMessage.getText())
> =A0case _ =3D> println("Oops, not a text message")
> }
> --
> James
> -------
> http://macstrac.blogspot.com/
>
> Open Source Integration
> http://fusesource.com/
>

James,

Thanks for the more idiomatic Scala code, we are starting to use scala
instead of java and have not explored all the scala subtelties :).

I tried with maxReconnectAttempts=3D1000, the consumer stops after 7
attempts to reconnect to the broker.

Regards.
Jean-Yves