public final class RMQManager extends Object implements RMQConnectionListener
| 修飾子とタイプ | メソッドと説明 |
|---|---|
boolean |
getChannelStatus(String queueName)
Gets status of channel for specified queue.
|
static RMQManager |
getInstance()
Gets instance.
|
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.
|
public static RMQManager getInstance()
public void update()
public void shutdown()
public void shutdownWithWait()
throws InterruptedException
InterruptedException - throw if wait process is interrupted.public boolean isOpen()
public boolean getChannelStatus(String queueName)
queueName - the queue name.public void onOpen(RMQConnection rmqConnection)
RMQConnectionListeneronOpen インタフェース内 RMQConnectionListenerrmqConnection - the connection.public void onCloseCompleted(RMQConnection rmqConnection)
RMQConnectionListeneronCloseCompleted インタフェース内 RMQConnectionListenerrmqConnection - the connection.Copyright © 2004-2013. All Rights Reserved.