[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Regular and intermittent interrupt/resume between broker and client connector


I have implemented the failover transport and TransportListener interface.
So, the transport listener receives the interrupt/resume and sets an
internal flag in the connector itself, lets call it connectionActive. When a
message gets dequeued for sending by the connector, I take an optimistic
approach and attempt to send. However we might be momentarily disconnected
and as the message was dequeued for send we end up discarding it. So what I
am thinking is to enqueue the unsent messages and to maintain them on a
queue until they are delivered with retry at configurable intervals.


Sent from:

( ! ) Warning: include(msgfooter.php): failed to open stream: No such file or directory in /var/www/git/apache-activemq-developers/msg08750.html on line 87
Call Stack
10.0007363192{main}( ).../msg08750.html:0

( ! ) Warning: include(): Failed opening 'msgfooter.php' for inclusion (include_path='.:/var/www/git') in /var/www/git/apache-activemq-developers/msg08750.html on line 87
Call Stack
10.0007363192{main}( ).../msg08750.html:0