Package com.sonymobile.jenkins.plugins.mq.mqnotifier

Class MQConnection

java.lang.Object

com.sonymobile.jenkins.plugins.mq.mqnotifier.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:

Örjan Percy <orjan.percy@sonymobile.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.
com.rabbitmq.client.Connection	getConnection()	Gets the connection.
static MQConnection	getInstance()	Gets the instance.
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	publish(net.sf.json.JSONObject json)	Publish json message on configured MQ server.
void	publish(net.sf.json.JSONObject json, String routingKey)	Publish json message on configured MQ server.
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 Detail

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

publish

public void publish(net.sf.json.JSONObject json)

Publish json message on configured MQ server. Helper method for testing, in order to use functional interfaces.

Parameters:

json - the message in json format

publish

public void publish(net.sf.json.JSONObject json,
                    String routingKey)

Publish json message on configured MQ server.

Parameters:

json - the message in json format

routingKey - the routing key to use for the message, unless overriden by global setting.

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