public interface ProviderListener
Modifier and Type | Method and Description |
---|---|
void |
onConnectionEstablished(URI remoteURI)
Called to indicate that the underlying connection to the Broker has been established
for the first time.
|
void |
onConnectionFailure(IOException ex)
Called to indicate that the underlying connection to the Broker has been lost and
the Provider will not perform any reconnect.
|
void |
onConnectionInterrupted(URI remoteURI)
Called from a fault tolerant Provider instance to signal that the underlying
connection to the Broker has been lost.
|
void |
onConnectionRecovered(Provider provider)
Called to indicate that a connection to the Broker has been reestablished and
that all recovery operations have succeeded and the connection will now be
transitioned to a recovered state.
|
void |
onConnectionRecovery(Provider provider)
Called to indicate that a connection to the Broker has been reestablished and
that notified listener should start to recover it's state.
|
void |
onConnectionRestored(URI remoteURI)
Called to signal that all recovery operations are now complete and the Provider
is again in a normal connected state.
|
void |
onInboundMessage(JmsInboundMessageDispatch envelope)
Called when a new Message has arrived for a registered consumer.
|
void |
onProviderException(Exception cause)
Called to indicate that a some client operation caused or received an
error that is not considered fatal at the provider level.
|
void |
onResourceRemotelyClosed(JmsResource resource,
Exception cause)
Called to indicate that a currently active resource has been closed on the
remote end due to management or other action.
|
void onInboundMessage(JmsInboundMessageDispatch envelope)
envelope
- The dispatch object containing the message and delivery information.void onConnectionInterrupted(URI remoteURI)
remoteURI
- The URI of the Broker whose connection was lost.void onConnectionRecovery(Provider provider) throws Exception
provider
- The new Provider instance that will become active after the state
has been recovered.Exception
- if an error occurs during recovery attempt, this will fail
the Provider that's being used for recovery.void onConnectionRecovered(Provider provider) throws Exception
provider
- The new Provider instance that will become active after the state
has been recovered.Exception
- if an error occurs during recovery attempt, this will fail
the Provider that's being used for recovery.void onConnectionRestored(URI remoteURI)
remoteURI
- The URI of the Broker that the client has now connected to.void onConnectionEstablished(URI remoteURI)
remoteURI
- The URI of the Broker that the client has now connected to.void onConnectionFailure(IOException ex)
ex
- The exception that indicates the cause of this Provider failure.void onResourceRemotelyClosed(JmsResource resource, Exception cause)
resource
- the JmsResource instance that has been remotely closed.cause
- optional exception object that indicates the cause of the close.void onProviderException(Exception cause)
cause
- the exception object that is being reported to the listener.Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.