Hi all, Should I open an issue in Jira ? Rgds. JY
On Tue, Feb 16, 2010 at 5:25 PM, Jean-Yves LEBLEU <jleb...@gmail.com> wrote: > 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.strac...@gmail.com> wrote: >> Which version are you using BTW? >> >> On 16 February 2010 16:17, Jean-Yves LEBLEU <jleb...@gmail.com> wrote: >>> On Tue, Feb 16, 2010 at 4:54 PM, James Strachan >>> <james.strac...@gmail.com> wrote: >>>> On 16 February 2010 15:38, Jean-Yves LEBLEU <jleb...@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=1000 >>>> >>>> >>>> BTW slightly more idiomatic Scala code for onMessage would be... >>>> >>>> def onMessage(message: Message): Unit = message match { >>>> case textMessage: TextMessage => println("Message recieved: " + >>>> textMessage.getText()) >>>> case _ => 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=1000, 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/ >> >
