org.jenkinsci.plugins.rabbitmqconsumer

クラス RMQManager

java.lang.Object

org.jenkinsci.plugins.rabbitmqconsumer.RMQManager

すべての実装されたインタフェース:

RMQConnectionListener

public final class RMQManager
extends Object
implements RMQConnectionListener

Manager class for RabbitMQ connection.

作成者:

rinrinne a.k.a. rin_ne

メソッドのサマリー

修飾子とタイプ	メソッドと説明
com.rabbitmq.client.Channel	getChannel() Gets channel.
boolean	getChannelStatus(String queueName) Gets status of channel for specified queue.
static RMQManager	getInstance() Gets instance.
PublishRMQChannel	getPublishChannel() Gets instance of PublishRMQChannel.
boolean	isOpen() Gets whether connection is established or not.
void	onCloseCompleted(RMQConnection rmqConnection) Calls when closing process for connection is completed.
void	onOpen(RMQConnection rmqConnection) Calls when connection is opend.
void	shutdown() Shutdown connection.
void	shutdownWithWait() Shutdown connection then wait to close connection.
void	update() Updates RabbitMQ connection.

クラスから継承されたメソッド java.lang.Object

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

メソッドの詳細

getInstance

public static RMQManager getInstance()

Gets instance.

戻り値:

the instance.

update

public void update()

Updates RabbitMQ connection.

shutdown

public void shutdown()

Shutdown connection.

shutdownWithWait

public void shutdownWithWait()
                      throws InterruptedException

Shutdown connection then wait to close connection.

例外:

InterruptedException - throw if wait process is interrupted.

isOpen

public boolean isOpen()

Gets whether connection is established or not.

戻り値:

true if connection is already established.

getChannelStatus

public boolean getChannelStatus(String queueName)

Gets status of channel for specified queue.

パラメータ:

queueName - the queue name.

戻り値:

true if channel for specified queue is already established.

getChannel

public com.rabbitmq.client.Channel getChannel()

Gets channel. Note that returned channel is not managed in any own classes.

戻り値:

the channel.

getPublishChannel

public PublishRMQChannel getPublishChannel()

Gets instance of PublishRMQChannel.

戻り値:

instance.

onOpen

public void onOpen(RMQConnection rmqConnection)

Calls when connection is opend.

定義:

onOpen インタフェース内 RMQConnectionListener

パラメータ:

rmqConnection - the connection.

onCloseCompleted

public void onCloseCompleted(RMQConnection rmqConnection)

Calls when closing process for connection is completed.

定義:

onCloseCompleted インタフェース内 RMQConnectionListener

パラメータ:

rmqConnection - the connection.