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