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

Methods

Modifier and Type	Method and Description
void	addMessageToQueue(String exchange, String routingKey, com.rabbitmq.client.AMQP.BasicProperties props, byte[] body) Puts a message in the message queue.
com.rabbitmq.client.Connection	getConnection() Gets the connection.
static MQConnection	getInstance() Gets the instance.
void	initialize(String name, hudson.util.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 Detail

getInstance

public static MQConnection getInstance()

Gets the instance.

Returns:

the instance

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,
              hudson.util.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