activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: TransportListener callback
Date Mon, 16 Aug 2010 13:02:38 GMT
should not, check out the source:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?view=markup
the reconnect mutex.

On 16 August 2010 13:01, vv <vanisathish@gmail.com> wrote:
>
> Can any out of order processing of the Transport Listener
> events(interrupted/resumed) and onMessage callback happen?
>
> i.e. if the link is unstable, and at the same time the producer keeps
> sending the messages to the consumer..
>
>
> vv wrote:
>>
>> Hi,
>>
>> Does the TransportListener & the Rx Message Listener(OnMessage) be called
>> from the same thread/context? during a transient link down/up event will
>> the transportInterrupted & transportResumed ,onmessage callback function
>> be called simulataneously. i.e. can there be a thread switching between
>> the processing of transportresumed & the onmessage callback processing.
>>
>>
>> Dejan Bosanac wrote:
>>>
>>> Hi John,
>>>
>>> TransportListener doesn't monitor if broker is going up and down, but
>>> monitors the status of your client's connection. It's set on the
>>> connection and it only provides a mechanism for the connection to
>>> notify your application on the events. It doesn't require any separate
>>> thread or context.
>>>
>>> Cheers
>>> --
>>> Dejan Bosanac - http://twitter.com/dejanb
>>>
>>> Open Source Integration - http://fusesource.com/
>>> ActiveMQ in Action - http://www.manning.com/snyder/
>>> Blog - http://www.nighttale.net
>>>
>>>
>>>
>>> On Mon, Aug 16, 2010 at 8:45 AM, John Peter <mrthaya@yahoo.com> wrote:
>>>>
>>>> Hi Guys,
>>>>
>>>> We use TransportListener for Broker Up/Down Status detection and around
>>>> 20
>>>> ActiveMQ Broker statuses need to be continuously monitored. Since
>>>> network is
>>>> non reliable, we receive the transportInterupted/ transportResumed are
>>>> being
>>>> called very frequently
>>>>
>>>> My Question is
>>>> 1) is TransportListener callback class running in separate Thread ? and
>>>> Which Context?
>>>>
>>>>  Thanks and Regards,
>>>>  John Peter.
>>>> --
>>>> View this message in context:
>>>> http://old.nabble.com/TransportListener-callback-tp29447156p29447156.html
>>>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>>>
>>>>
>>>
>>>
>>> -----
>>> Dejan Bosanac
>>>
>>> Open Source Integration - http://fusesource.com/
>>> ActiveMQ in Action - http://www.manning.com/snyder/
>>> Blog - http://www.nighttale.net
>>>
>>
>>
>
> --
> View this message in context: http://old.nabble.com/TransportListener-callback-tp29447156p29449143.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>



-- 
http://blog.garytully.com

Open Source Integration
http://fusesource.com

Mime
View raw message