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
