com.redhat.jenkins.plugins.amqpbuildtrigger

Class ConnectionManager

java.lang.Object

com.redhat.jenkins.plugins.amqpbuildtrigger.ConnectionManager

All Implemented Interfaces:

org.apache.qpid.jms.JmsConnectionListener

public class ConnectionManager
extends Object
implements org.apache.qpid.jms.JmsConnectionListener

Constructor Summary

Constructors

Constructor and Description
ConnectionManager()

Method Summary

Modifier and Type	Method and Description
protected void	addBuildTrigger(AmqpBuildTrigger trigger)
static ConnectionManager	getInstance()
void	initialize()
void	onConnectionEstablished(URI remoteURI)
void	onConnectionFailure(Throwable error)
void	onConnectionInterrupted(URI remoteURI)
void	onConnectionRestored(URI remoteURI)
void	onConsumerClosed(javax.jms.MessageConsumer consumer, Throwable cause)
void	onInboundMessage(org.apache.qpid.jms.message.JmsInboundMessageDispatch envelope)
void	onProducerClosed(javax.jms.MessageProducer producer, Throwable cause)
void	onSessionClosed(javax.jms.Session session, Throwable cause)
void	shutdown()
void	update()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectionManager

public ConnectionManager()

Method Detail

getInstance

public static ConnectionManager getInstance()

addBuildTrigger

protected void addBuildTrigger(AmqpBuildTrigger trigger)

initialize

public void initialize()

update

public void update()

shutdown

public void shutdown()

onConnectionEstablished

public void onConnectionEstablished(URI remoteURI)

Specified by:

onConnectionEstablished in interface org.apache.qpid.jms.JmsConnectionListener

onConnectionFailure

public void onConnectionFailure(Throwable error)

Specified by:

onConnectionFailure in interface org.apache.qpid.jms.JmsConnectionListener

onConnectionInterrupted

public void onConnectionInterrupted(URI remoteURI)

Specified by:

onConnectionInterrupted in interface org.apache.qpid.jms.JmsConnectionListener

onConnectionRestored

public void onConnectionRestored(URI remoteURI)

Specified by:

onConnectionRestored in interface org.apache.qpid.jms.JmsConnectionListener

onInboundMessage

public void onInboundMessage(org.apache.qpid.jms.message.JmsInboundMessageDispatch envelope)

Specified by:

onInboundMessage in interface org.apache.qpid.jms.JmsConnectionListener

onSessionClosed

public void onSessionClosed(javax.jms.Session session,
                            Throwable cause)

Specified by:

onSessionClosed in interface org.apache.qpid.jms.JmsConnectionListener

onConsumerClosed

public void onConsumerClosed(javax.jms.MessageConsumer consumer,
                             Throwable cause)

Specified by:

onConsumerClosed in interface org.apache.qpid.jms.JmsConnectionListener

onProducerClosed

public void onProducerClosed(javax.jms.MessageProducer producer,
                             Throwable cause)

Specified by:

onProducerClosed in interface org.apache.qpid.jms.JmsConnectionListener