activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ZhiPeng Yang <zpy...@mobvoi.com>
Subject embedding apollo broker in my java application
Date Wed, 10 Dec 2014 06:31:41 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message