activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ong hean kuan" <mysurf...@gmail.com>
Subject activemq-cpp: implement reconnection on consumer and producer
Date Thu, 25 Oct 2007 02:07:21 GMT
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

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