External topic subscriber to fabric can't create session
Issue
- User is trying to create external
TOPICsubscriber as standalonejavaclient. - But always get the following error and can't set listener.
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1068)
17:13:08 INFO Opening socket connection to server HOSTNAME/IP:2181. Will not attempt to authenticate using SASL (unknown error)
17:13:09 INFO Socket connection established to HOSTNAME/IP:2181, initiating session
17:13:09 INFO Session establishment complete on server HOSTNAME/IP:2181, sessionid = 0x14ddd8c6950004d, negotiated timeout = 40000
17:13:09 INFO State change: CONNECTED
17:13:09 WARN There are no ConnectionStateListeners registered.
17:13:09 INFO ****** connection start
17:13:11 INFO Adding new broker connection URL: tcp://HOSTNAME:49044
17:13:12 INFO Successfully connected to tcp://HOSTNAME:49044
17:13:12 INFO ****** session: ActiveMQSession {id=ID:xyz-1:1:1,started=false}
17:13:12 INFO ****** receiver ActiveMQMessageConsumer { value=ID:xyz-1:1:1:1, started=false }
17:13:12 WARN Transport (tcp://HOSTNAME/IP:49044@54580) failed, reason: , attempting to automatically reconnect
java.io.EOFException
at java.io.DataInputStream.readInt(DataInputStream.java:392)
at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258)
at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221)
at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
at java.lang.Thread.run(Thread.java:745)
17:13:12 INFO Successfully reconnected to tcp://HOSTNAME:49044
17:13:13 INFO Session: 0x14ddd8c6950004d closed
Brokeris created following way
mq-create --create-container br --replicas 2 --group mq-master-slave-group example-broker
- Is there something missing in code ?
Environment
- Red Hat JBoss Fuse
- 6.1.0
Subscriber exclusive content
A Red Hat subscription provides unlimited access to our knowledgebase, tools, and much more.