public abstract class AbstractRMQChannel extends Object implements RMQChannelNotifier, com.rabbitmq.client.ShutdownListener
| 修飾子とタイプ | フィールドと説明 |
|---|---|
protected com.rabbitmq.client.Channel |
channel |
protected Collection<RMQChannelListener> |
rmqChannelListeners |
protected RMQState |
state |
| コンストラクタと説明 |
|---|
AbstractRMQChannel()
Default constructor.
|
| 修飾子とタイプ | メソッドと説明 |
|---|---|
void |
addRMQChannelListener(RMQChannelListener rmqChannelListener)
Add
RMQChannelListener. |
void |
close()
Close channel.
|
com.rabbitmq.client.Channel |
getChannel()
Gets channel.
|
boolean |
isOpen()
Gets whether channel is opened.
|
boolean |
isOpenRMQChannel()
Gets whether actual RabbitMQ channel is opened.
|
void |
notifyOnCloseCompleted()
Notify OnCloseCompleted event.
|
void |
notifyOnOpen()
Notify OnOpen event.
|
void |
notifyRMQChannelListeners(RMQChannelEvent event)
Notify
RMQChannelListeners. |
void |
open(com.rabbitmq.client.Connection connection)
Open connection.
|
void |
removeRMQChannelListener(RMQChannelListener rmqChannelListener)
Removes
RMQChannelListener. |
void |
shutdownCompleted(com.rabbitmq.client.ShutdownSignalException shutdownSignalException) |
protected com.rabbitmq.client.Channel channel
protected RMQState state
protected final Collection<RMQChannelListener> rmqChannelListeners
public boolean isOpen()
public void open(com.rabbitmq.client.Connection connection)
throws IOException
connection - the instance of Connection, not RMQConnection.IOException - exception if channel cannot be created.public com.rabbitmq.client.Channel getChannel()
public void close()
throws IOException
IOException - throws if something error.public void addRMQChannelListener(RMQChannelListener rmqChannelListener)
RMQChannelListener.addRMQChannelListener インタフェース内 RMQChannelNotifierrmqChannelListener - the channel listener.public void removeRMQChannelListener(RMQChannelListener rmqChannelListener)
RMQChannelListener.removeRMQChannelListener インタフェース内 RMQChannelNotifierrmqChannelListener - the channel listener.public boolean isOpenRMQChannel()
isOpenRMQChannel インタフェース内 RMQChannelNotifierpublic void notifyRMQChannelListeners(RMQChannelEvent event)
RMQChannelListeners.notifyRMQChannelListeners インタフェース内 RMQChannelNotifierevent - the event for channel.public void notifyOnCloseCompleted()
public void notifyOnOpen()
public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException shutdownSignalException)
shutdownCompleted インタフェース内 com.rabbitmq.client.ShutdownListenershutdownSignalException - the exception.Copyright © 2016–2018. All rights reserved.