Why have you configured 10.80.1.1 to connect to itself, and why are 2 and 3 default configurations?
More generally, what are you trying to accomplish here? I assume you've read the content at http://activemq.apache.org/masterslave.html, but if not, you need to. On Sep 1, 2015 3:25 AM, "wang" <w...@kai.co.jp> wrote: > Hi guys > > I am Wang and I facing problem when i configured MQTT master-slave using > activeMQ 5.12 > I have three servers: 10.80.1.1, 10.80.1.2, 10.80.1.3 > I deployed default activeMQ instance onto 10.80.1.2, 10.80.1.3. > And I added the following networkConnectors to server 10.80.1.1 : > > <networkConnectors> > <networkConnector uri="masterslave:(tcp://10.80.1.1:1883 > ,tcp://10.80.1.2:1883,tcp://10.80.1.3:1883)"/> > </networkConnectors> > > I can started server 10.80.1.2 and server 10.80.1.3, but when I try to > start server 10.80.1.1 > I got the following errors: > > WARN | Transport Connection to: tcp://10.80.1.1:37442 failed: > org.apache.activemq.transport.InactivityIOException: Channel was inactive > for too (>60000) long: tcp://10.80.1.1:37442 > INFO | Establishing network connection from vm://10.80.1.1?async=false > to failover:(tcp://10.80.1.1:1883,tcp://10.80.1.2:1883 > ,tcp://10.80.1.3:1883)?randomize=false&maxReconnectAttempts=0 > INFO | Connector vm://10.80.1.1 started > INFO | Successfully connected to tcp://10.80.1.1:1883 > WARN | Exception occurred processing: > MQTTFrame { type: unknown, qos: AT_MOST_ONCE, dup:false }: > org.apache.activemq.transport.mqtt.MQTTProtocolException: Unknown MQTTFrame > type: 0 > WARN | Transport (tcp://10.80.1.1:1883) failed, not attempting to > automatically reconnect > java.io.EOFException > at > java.io.DataInputStream.readInt(DataInputStream.java:392)[:1.7.0_79] > at > org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:267)[activemq-client-5.12.0.jar:5.12.0] > at > org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)[activemq-client-5.12.0.jar:5.12.0] > at > org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)[activemq-client-5.12.0.jar:5.12.0] > at > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)[activemq-client-5.12.0.jar:5.12.0] > at java.lang.Thread.run(Thread.java:745)[:1.7.0_79] > INFO | Network connection between vm://10.80.1.1#86 and unconnected > shutdown due to a local error: java.lang.Throwable: remoteBrokerInfo is null > INFO | Connector vm://10.80.1.1 stopped > INFO | 10.80.1.1 bridge to Unknown stopped > > who could give me some hints to solve this problem? > > Regards, > Wang > > >
