org.apache.qpid.jms

Interface JmsConnectionListener

public interface JmsConnectionListener

Providers an interface for client's to listener to events related to an JmsConnection.

Method Summary

Modifier and Type	Method and Description
void	onConnectionEstablished(URI remoteURI) Called when a connection has been successfully established.
void	onConnectionFailure(Throwable error) Called when an unrecoverable error occurs and the Connection must be closed.
void	onConnectionInterrupted(URI remoteURI) Called when the Connection to the remote peer is lost.
void	onConnectionRestored(URI remoteURI) Called when normal communication has been restored to a remote peer.
void	onConsumerRemotelyClosed(javax.jms.MessageConsumer consumer, Exception cause) Called when the remote peer closes a MessageConsumer.
void	onInboundMessage(JmsInboundMessageDispatch envelope) Called when a Connection is notified that a new Message has arrived for one of it's currently active subscriptions.
void	onProducerRemotelyClosed(javax.jms.MessageProducer producer, Exception cause) Called when the remote peer closes a MessageProducer.
void	onSessionRemotelyClosed(javax.jms.Session session, Exception cause) Called when the remote peer closes a session.

Method Detail

onConnectionEstablished

void onConnectionEstablished(URI remoteURI)

Called when a connection has been successfully established. This method is never called more than once when using a fault tolerant connection, instead the connection will signal interrupted and restored.

Parameters:

remoteURI - The URI of the Broker this client is now connected to.

onConnectionFailure

void onConnectionFailure(Throwable error)

Called when an unrecoverable error occurs and the Connection must be closed.

Parameters:

error - The error that triggered the failure.

onConnectionInterrupted

void onConnectionInterrupted(URI remoteURI)

Called when the Connection to the remote peer is lost.

Parameters:

remoteURI - The URI of the Broker previously connected to.

onConnectionRestored

void onConnectionRestored(URI remoteURI)

Called when normal communication has been restored to a remote peer.

Parameters:

remoteURI - The URI of the Broker that this client is now connected to.

onInboundMessage

void onInboundMessage(JmsInboundMessageDispatch envelope)

Called when a Connection is notified that a new Message has arrived for one of it's currently active subscriptions.

Parameters:

envelope - The envelope that contains the incoming message and it's delivery information.

onSessionRemotelyClosed

void onSessionRemotelyClosed(javax.jms.Session session,
                             Exception cause)

Called when the remote peer closes a session.

Parameters:

session - The session that was closed on the remote end.

cause - The exception that provides additional context on the remote closure.

onConsumerRemotelyClosed

void onConsumerRemotelyClosed(javax.jms.MessageConsumer consumer,
                              Exception cause)

Called when the remote peer closes a MessageConsumer.

Parameters:

consumer - The consumer that was closed on the remote end.

cause - The exception that provides additional context on the remote closure.

onProducerRemotelyClosed

void onProducerRemotelyClosed(javax.jms.MessageProducer producer,
                              Exception cause)

Called when the remote peer closes a MessageProducer.

Parameters:

producer - The producer that was closed on the remote end.

cause - The exception that provides additional context on the remote closure.