void |
Proxy.basicAck(AMQP.Basic.Ack ack) |
static Boolean |
StubAgentIn.basicCancel(String consumerTag,
String queueName,
int channelNumber,
short serverId,
long proxyId) |
void |
Proxy.basicReject(AMQP.Basic.Reject basicReject) |
private static void |
StubLocal.checkName(String name) |
private void |
Proxy.doCancel(String consumerTag,
int channelNumber,
QueueShell queueShell) |
static void |
StubAgentIn.exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare) |
static void |
StubLocal.exchangeDeclare(String exchangeName,
String type,
boolean durable,
boolean passive) |
static void |
StubAgentIn.exchangeDelete(AMQP.Exchange.Delete exchangeDelete) |
void |
Proxy.exchangeDelete(AMQP.Exchange.Delete exchangeDelete) |
static void |
StubLocal.exchangeDelete(String exchangeName,
boolean ifUnused) |
static AMQP.Queue.DeclareOk |
StubAgentIn.queueDeclare(AMQP.Queue.Declare queueDeclare,
short serverId,
long proxyId) |
static AMQP.Queue.DeclareOk |
StubLocal.queueDeclare(String queueName,
boolean passive,
boolean durable,
boolean autoDelete,
boolean exclusive,
short serverId,
long proxyId) |
AMQP.Queue.DeleteOk |
Proxy.queueDelete(AMQP.Queue.Delete queueDelete) |
static AMQP.Queue.DeleteOk |
StubAgentIn.queueDelete(AMQP.Queue.Delete queueDelete,
short serverId,
long proxyId) |
static int |
StubLocal.queueDelete(String queueName,
boolean ifUnused,
boolean ifEmpty,
short serverId,
long proxyId) |
void |
Proxy.txCommit(int channelNumber) |
void |
Proxy.txRollback(int channelNumber) |