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
 74.125.78.144 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=XpDtr1pcZuEnqtqSPkJHTz9Tid7gwES2pfl+UwgDCODDYb6c3zRUSNBICRzoomB1+l
         X/0VaoKpmIV9XzfvtbZqqC2iwCcAdWmYUVLy00smp+J6+AQzjCLL6FZGkjld1Gg1yGma
         ig7Y0Z331Sy+HUg1FdwxANkq996v3LRhu1qS8=
MIME-Version: 1.0
In-Reply-To: <ec6e67fd1002160820r70b34aanaf73e0204e148722@mail.gmail.com>
References: <e870fe0e1002160738s16c7ca38kb0ef0d4b5b6bb994@mail.gmail.com>
	 <ec6e67fd1002160754r51bbb6bav5607330cc71e44a@mail.gmail.com>
	 <e870fe0e1002160817x506d4aebm2a4f5ef10a57c57d@mail.gmail.com>
	 <ec6e67fd1002160820r70b34aanaf73e0204e148722@mail.gmail.com>
Date: Tue, 16 Feb 2010 17:25:43 +0100
Message-ID: <e870fe0e1002160825t5a8c66e2xd8799220712e2433@mail.gmail.com>
Subject: Re: Consumer and Failover
From: Jean-Yves LEBLEU <jlebleu@gmail.com>
To: users@activemq.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

We are using 5.3.0, but have the same problem in 5.2.0


On Tue, Feb 16, 2010 at 5:20 PM, James Strachan
<james.strachan@gmail.com> wrote:
> Which version are you using BTW?
>
> On 16 February 2010 16:17, Jean-Yves LEBLEU <jlebleu@gmail.com> wrote:
>> 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
>>
>
>
>
> --
> James
> -------
> http://macstrac.blogspot.com/
>
> Open Source Integration
> http://fusesource.com/
>