org.jenkinsci.plugins.rabbitmqconsumer.channels

クラス ConsumeRMQChannel

java.lang.Object

org.jenkinsci.plugins.rabbitmqconsumer.channels.AbstractRMQChannel

org.jenkinsci.plugins.rabbitmqconsumer.channels.ConsumeRMQChannel

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

com.rabbitmq.client.ShutdownListener, EventListener, RMQChannelNotifier

public class ConsumeRMQChannel
extends AbstractRMQChannel

Handle class for RabbitMQ consume channel.

作成者:

rinrinne a.k.a. rin_ne

ネストされたクラスのサマリー

ネストされたクラス

修飾子とタイプ	クラスと説明
class	ConsumeRMQChannel.MessageConsumer Handle class that consume message.

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
protected Collection<String>	appIds

クラスから継承されたフィールド org.jenkinsci.plugins.rabbitmqconsumer.channels.AbstractRMQChannel

channel, rmqChannelListeners, state

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
ConsumeRMQChannel(String queueName, Collection<String> appIds) Creates instance with specified parameters.

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	consume() Starts consume.
Collection<String>	getAppIds() Get hashset of app ids.
String	getQueueName() Gets queue name.
boolean	isConsumeStarted() Gets whether consumer is already started or not.
void	shutdownCompleted(com.rabbitmq.client.ShutdownSignalException shutdownSignalException)

クラスから継承されたメソッド org.jenkinsci.plugins.rabbitmqconsumer.channels.AbstractRMQChannel

addRMQChannelListener, close, getChannel, isOpen, isOpenRMQChannel, notifyOnCloseCompleted, notifyOnOpen, notifyRMQChannelListeners, open, removeRMQChannelListener

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

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

フィールドの詳細

appIds

protected final Collection<String> appIds

コンストラクタの詳細

ConsumeRMQChannel

public ConsumeRMQChannel(String queueName,
                         Collection<String> appIds)

Creates instance with specified parameters.

パラメータ:

queueName - the queue name.

appIds - the hashset of application id.

メソッドの詳細

getAppIds

public Collection<String> getAppIds()

Get hashset of app ids.

戻り値:

the hashset of app ids.

getQueueName

public String getQueueName()

Gets queue name.

戻り値:

the queue name.

consume

public void consume()

Starts consume.

isConsumeStarted

public boolean isConsumeStarted()

Gets whether consumer is already started or not.

戻り値:

true if consumer is already started.

shutdownCompleted

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

定義:

shutdownCompleted インタフェース内 com.rabbitmq.client.ShutdownListener

オーバーライド:

shutdownCompleted クラス内 AbstractRMQChannel

パラメータ:

shutdownSignalException - the exception.