Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (herse.apache.org: domain of lists@nabble.com designates
 72.21.53.35 as permitted sender)
Message-ID: <9160414.post@talk.nabble.com>
Date: Mon, 26 Feb 2007 07:10:05 -0800 (PST)
From: naga007 <NSogal@gmail.com>
To: users@activemq.apache.org
Subject: Re: [Spam: 5.0] Network/Cluster of Brokers - Please help
In-Reply-To: <9159928.post@talk.nabble.com>
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
References: <9159928.post@talk.nabble.com>


use failover:(tcp://host1:61616,tcp://host2:61616) uri format for the
client.s


Gaurav Hariani wrote:
> 
> I'm trying to setup a cluster of Brokers (standalone) which clients can
> connect to (ideally I would like them to be discovered)
> listening to a TOPIC. In the case of a broker failing, the clients
> connected to that broker should reconnect to another broker.
> 
> I'm able to get clients to connect to a random broker (given a static
> list), but when I kill a broker, clients connected to that broker die with
> the following exception:
> 
> Feb 23, 2007 4:28:47 PM
> org.apache.activemq.transport.failover.FailoverTransport
> handleTransportFailure
> INFO: Transport failed, attempting to automatically reconnect due to:
> java.net.SocketException: Connection reset java.net.SocketException:
> Connection reset
>        at java.net.SocketInputStream.read(Unknown Source)
>        at
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.fill(TcpBufferedInputStream.java:49)
>        at
> org.apache.activemq.transport.tcp.TcpBufferedInputStream.read(TcpBufferedInputStream.java:56)
>        at java.io.DataInputStream.readInt(Unknown Source)
>        at
> org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)
>        at
> org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:156)
>        at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:136)
>        at java.lang.Thread.run(Unknown Source)
> 
> Also restarting the broker and the disconnected clients the restarted
> clients don't get messages from the other clients.
> 
> The clients are using the following URL to connect:
> java.naming.provider.url=static://(tcp://host1:61616,tcp://host2:61616)?failover=true
> 
> 
> The brokers are configured with the following
> 
> host1:
>    <transportConnectors>
>       <transportConnector name="openwire" uri="tcp://host1:61616"
> discoveryUri="multicast://default"/>
>    </transportConnectors>
>    <networkConnectors>
>      <networkConnector name="host1 and host2"
> uri="static://(tcp://host1:61616,tcp://host2:61616)" failover="true"/>
>    </networkConnectors>
> 
> 
> host2:
>    <transportConnectors>
>       <transportConnector name="openwire" uri="tcp://host2:61616"
> discoveryUri="multicast://default"/>
>    </transportConnectors>
>    <networkConnectors>
>      <networkConnector name="host1 and host2"
> uri="static://(tcp://host1:61616,tcp://host2:61616)" failover="true"/>
>    </networkConnectors>
> 
> 
> 
> Is there something obvious that I'm missing.
> Also is there possible to use similar clients using the .NET API?
> 
> Thanks,
> 
> Gaurav Hariani
> 
> 
> 
> 

-- 
View this message in context: http://www.nabble.com/Network-Cluster-of-Brokers---Please-help-tf3293180s2354.html#a9160414
Sent from the ActiveMQ - User mailing list archive at Nabble.com.