You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by ZhiPeng Yang <zp...@mobvoi.com> on 2014/12/10 07:31:41 UTC
embedding apollo broker in my java application
Hi,
when I runing the example-embedded-broker attached in the apollo
archive. And using Eclipse paho client to connect to this broker. the
embedded -broker throw following exceptions :
14:31:15,652 INFO org.apache.activemq.apollo.log.connection : 143 -
connected: local:/127.0.0.1:61613, remote:/127.0.0.1:47906
14:31:15,662 INFO
org.apache.activemq.apollo.broker.protocol.ProtocolHandler : 163 -
java.io.IOException: Could not identify the protocol.
14:31:15,663 INFO stacktrace : 164 - java.io.IOException: Could not
identify the protocol.
java.io.IOException: Could not identify the protocol.
at
org.apache.activemq.apollo.broker.protocol.AnyProtocolCodec.read(AnyProtocol.scala:97)
at
org.fusesource.hawtdispatch.transport.TcpTransport.drainInbound(TcpTransport.java:706)
at
org.fusesource.hawtdispatch.transport.TcpTransport$6.run(TcpTransport.java:588)
at
org.fusesource.hawtdispatch.internal.NioDispatchSource$3.run(NioDispatchSource.java:209)
at
org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
at
org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
14:31:15,664 INFO org.apache.activemq.apollo.log.connection : 143 -
disconnected: local:/127.0.0.1:61613, remote:/127.0.0.1:47906
14:31:15,667 INFO org.apache.activemq.apollo.log.connection : 143 -
connected: local:/127.0.0.1:61613, remote:/127.0.0.1:47907
14:31:15,668 INFO
org.apache.activemq.apollo.broker.protocol.ProtocolHandler : 163 -
java.io.IOException: Could not identify the protocol.
14:31:15,668 INFO stacktrace : 164 - java.io.IOException: Could not
identify the protocol.
java.io.IOException: Could not identify the protocol.
at
org.apache.activemq.apollo.broker.protocol.AnyProtocolCodec.read(AnyProtocol.scala:97)
at
org.fusesource.hawtdispatch.transport.TcpTransport.drainInbound(TcpTransport.java:706)
at
org.fusesource.hawtdispatch.transport.TcpTransport$9.run(TcpTransport.java:770)
at
org.fusesource.hawtdispatch.internal.SerialDispatchQueue.run(SerialDispatchQueue.java:100)
at
org.fusesource.hawtdispatch.internal.pool.SimpleThread.run(SimpleThread.java:77)
14:31:15,670 INFO org.apache.activemq.apollo.log.connection : 143 -
disconnected: local:/127.0.0.1:61613, remote:/127.0.0.1:47907
thanks,
roger