public class RMQConnection extends Object implements com.rabbitmq.client.ShutdownListener, RMQChannelListener, RMQConnectionNotifier
| コンストラクタと説明 |
|---|
RMQConnection(String serviceUri)
Creates instance with specified parameter.
|
| 修飾子とタイプ | メソッドと説明 |
|---|---|
void |
addRMQConnectionListener(RMQConnectionListener rmqConnectionListener)
|
void |
close()
Close connection.
|
boolean |
getChannelStatus(String queueName)
Gets status of channel bins specified queue.
|
List<RMQChannel> |
getRMQChannels()
Gets the list of RMQChannels.
|
String |
getServiceUri()
Gets URI for RabbitMQ service.
|
boolean |
isOpen()
Gets if connection is established.
|
boolean |
isOpenRMQConnection()
Gets whether connection is opened.
|
void |
notifyOnCloseCompleted()
Notify OnCloseCompleted event.
|
void |
notifyOnOpen()
Notify OnOpen event.
|
void |
notifyRMQConnectionListeners(RMQConnectionEvent event)
Notify event for
RMQConnection. |
void |
onCloseCompleted(RMQChannel rmqChannel)
Calls when close process for channel is completed.
|
void |
onOpen(RMQChannel rmqChannel)
Calls when channel is opend.
|
void |
open()
Open connection.
|
void |
removeRMQConnectionListener(RMQConnectionListener rmqConnectionListener)
Removes
RMQConnectionListener. |
void |
shutdownCompleted(com.rabbitmq.client.ShutdownSignalException shutdownSignalException) |
void |
updateChannels(List<RabbitmqConsumeItem> consumeItems)
Updates each channels.
|
public RMQConnection(String serviceUri)
serviceUri - the URI for RabbitMQ service.public String getServiceUri()
public List<RMQChannel> getRMQChannels()
public boolean getChannelStatus(String queueName)
queueName - the queue name.public void open()
throws IOException
IOException - thow if connection cannot be opend.public void close()
public boolean isOpen()
public void updateChannels(List<RabbitmqConsumeItem> consumeItems)
consumeItems - the list of consume items.public void onOpen(RMQChannel rmqChannel)
RMQChannelListeneronOpen インタフェース内 RMQChannelListenerrmqChannel - the channel.public void onCloseCompleted(RMQChannel rmqChannel)
RMQChannelListeneronCloseCompleted インタフェース内 RMQChannelListenerrmqChannel - the channel.public void addRMQConnectionListener(RMQConnectionListener rmqConnectionListener)
RMQConnectionNotifieraddRMQConnectionListener インタフェース内 RMQConnectionNotifierrmqConnectionListener - the connection listener.public void removeRMQConnectionListener(RMQConnectionListener rmqConnectionListener)
RMQConnectionNotifierRMQConnectionListener.removeRMQConnectionListener インタフェース内 RMQConnectionNotifierrmqConnectionListener - the connection listener.public boolean isOpenRMQConnection()
RMQConnectionNotifierisOpenRMQConnection インタフェース内 RMQConnectionNotifierpublic void notifyRMQConnectionListeners(RMQConnectionEvent event)
RMQConnectionNotifierRMQConnection.notifyRMQConnectionListeners インタフェース内 RMQConnectionNotifierevent - the event for connection.public void notifyOnCloseCompleted()
public void notifyOnOpen()
public void shutdownCompleted(com.rabbitmq.client.ShutdownSignalException shutdownSignalException)
shutdownCompleted インタフェース内 com.rabbitmq.client.ShutdownListenershutdownSignalException - the exception.Copyright © 2004-2013. All Rights Reserved.