Dear All:
I am implementing reconnection on consumer,
i create a consumer class with ExceptionListener, and a thread class active
if the 2 exception receives
OpenWireConnector::onCommand - Broker closed this connection.
or
activemq::io::SocketInputStream::read - The connection is broken
My reconnect function is at consumer class, which i pass a pointer to Thread
class, so it will call it periodically if conne
I restart ActiveMQ to test, first time it success without problem, but
second time, i received additional exception
AsyncSendTransport::run - Connector threw an unknown Exception,
recovering...
FILE: activemq/transport/filters/AsyncSendTransport.cpp, LINE: 141
but it still successfully reconnect.
I have no idea why this exception occur, will it cause any problem?
--
Hean Kuan Ong
http://linux.byexamples.com
http://cc.byexamples.com
http://wordpress.byexamples.com