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
RMQChannelListener s. |
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
インタフェース内 RMQChannelNotifier
rmqChannelListener
- the channel listener.public void removeRMQChannelListener(RMQChannelListener rmqChannelListener)
RMQChannelListener
.removeRMQChannelListener
インタフェース内 RMQChannelNotifier
rmqChannelListener
- the channel listener.public boolean isOpenRMQChannel()
isOpenRMQChannel
インタフェース内 RMQChannelNotifier
public void notifyRMQChannelListeners(RMQChannelEvent event)
RMQChannelListener
s.notifyRMQChannelListeners
インタフェース内 RMQChannelNotifier
event
- the event for channel.public void notifyOnCloseCompleted()
public void notifyOnOpen()
public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException shutdownSignalException)
shutdownCompleted
インタフェース内 com.rabbitmq.client.ShutdownListener
shutdownSignalException
- the exception.Copyright © 2016–2018. All rights reserved.