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/ >
