Package com.axis.jenkins.plugins.eiffel.eiffelbroadcaster

Class MQConnection

java.lang.Object

com.axis.jenkins.plugins.eiffel.eiffelbroadcaster.MQConnection

All Implemented Interfaces:

com.rabbitmq.client.ShutdownListener, EventListener

public final class MQConnection
extends Object
implements com.rabbitmq.client.ShutdownListener

Creates an MQ connection.

Author:

Isac Holm <isac.holm@axis..com>

Method Summary

Modifier and Type	Method	Description
void	addMessageToQueue(String exchange, String routingKey, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body)	Puts a message in the message queue.
void	clearOutstandingConfirms()	Clear the outstanding confirms list, useful when testing.
void	clearQueue()	Clears the queue of outbound events by discarding all events in it.
com.rabbitmq.client.Connection	getConnection()	Gets the connection.
static MQConnection	getInstance()	Gets the instance.
List<String>	getQueueSnapshot()	Gets a snapshot of the current contents of the queue of outbound events.
int	getSizeOutstandingConfirms()	Get the number of currently outstanding confirms.
void	initialize(String name, Secret password, String uri, String vh)	Initializes this instance with supplied values.
void	shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)

Methods inherited from class java.lang.Object

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

Method Details

getQueueSnapshot

public List<String> getQueueSnapshot()

Gets a snapshot of the current contents of the queue of outbound events.

clearQueue

public void clearQueue()

Clears the queue of outbound events by discarding all events in it.

getInstance

public static MQConnection getInstance()

Gets the instance.

Returns:

the instance

getSizeOutstandingConfirms

public int getSizeOutstandingConfirms()

Get the number of currently outstanding confirms.

Returns:

the number of currently outstanding confirms

clearOutstandingConfirms

public void clearOutstandingConfirms()

Clear the outstanding confirms list, useful when testing.

addMessageToQueue

public void addMessageToQueue(String exchange,
 String routingKey,
 com.rabbitmq.client.AMQP.BasicProperties props,
 byte[] body)

Puts a message in the message queue.

Parameters:

exchange - the exchange to publish the message to

routingKey - the routing key

props - other properties for the message - routing headers etc

body - the message body

getConnection

public com.rabbitmq.client.Connection getConnection()

Gets the connection.

Returns:

the connection.

initialize

public void initialize(String name,
 Secret password,
 String uri,
 String vh)

Initializes this instance with supplied values.

Parameters:

name - the user name

password - the user password

uri - the server uri

vh - the virtual host

shutdownCompleted

public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException cause)

Specified by:

shutdownCompleted in interface com.rabbitmq.client.ShutdownListener