private static void |
StubAgentIn.addBoundExchange(AddBoundExchange request,
short serverId,
long proxyId) |
void |
Queue.addBoundExchange(String exchange,
short serverId,
long proxyId) |
void |
Proxy.basicCancel(String consumerTag,
int channelNumber) |
static Boolean |
StubAgentIn.basicCancel(String consumerTag,
String queueName,
int channelNumber,
short serverId,
long proxyId) |
void |
Proxy.basicConsume(AMQP.Basic.Consume basicConsume) |
static void |
StubAgentIn.basicConsume(AMQP.Basic.Consume basicConsume,
short serverId,
long proxyId) |
static void |
StubLocal.basicConsume(DeliveryListener deliveryListener,
String queueName,
String consumerTag,
boolean exclusive,
boolean noAck,
boolean noLocal,
int channelNumber,
short serverId,
long proxyId) |
GetResponse |
Proxy.basicGet(AMQP.Basic.Get basicGet) |
static Message |
StubAgentIn.basicGet(AMQP.Basic.Get basicGet,
short serverId,
long proxyId) |
static Message |
StubLocal.basicGet(String queueName,
boolean noAck,
short serverId,
long proxyId) |
void |
Queue.cancel(String consumerTag,
int channelNumber,
short serverId,
long proxyId) |
int |
Queue.clear(short serverId,
long proxyId) |
void |
Queue.consume(DeliveryListener proxy,
int channelId,
String consumerTag,
boolean exclusiveConsumer,
boolean noAck,
boolean noLocal,
short serverId,
long proxyId) |
void |
Queue.deleteQueue(String queueName,
short serverId,
long proxyId) |
private void |
Proxy.doCancel(String consumerTag,
int channelNumber,
QueueShell queueShell) |
AMQP.Queue.DeclareOk |
Queue.getInfo(short serverId,
long proxyId) |
void |
Proxy.queueBind(AMQP.Queue.Bind queueBind) |
static void |
StubAgentIn.queueBind(AMQP.Queue.Bind queueBind,
short serverId,
long proxyId) |
static void |
StubLocal.queueBind(String queueName,
String exchangeName,
String routingKey,
Map<String,Object> arguments,
short serverId,
long proxyId) |
AMQP.Queue.DeclareOk |
Proxy.queueDeclare(AMQP.Queue.Declare queueDeclare) |
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) |
AMQP.Queue.PurgeOk |
Proxy.queuePurge(AMQP.Queue.Purge queuePurge) |
static AMQP.Queue.PurgeOk |
StubAgentIn.queuePurge(AMQP.Queue.Purge queuePurge,
short serverId,
long proxyId) |
static int |
StubLocal.queuePurge(String queueName,
short serverId,
long proxyId) |
static void |
StubAgentIn.queueUnbind(AMQP.Queue.Unbind queueUnbind,
short serverId,
long proxyId) |
static void |
StubLocal.queueUnbind(String exchangeName,
String queueName,
String routingKey,
Map<String,Object> arguments,
short serverId,
long proxyId) |
Message |
Queue.receive(boolean noAck,
short serverId,
long proxyId) |
private static void |
StubAgentIn.removeBoundExchange(RemoveBoundExchange request,
short serverId,
long proxyId) |
void |
Queue.removeBoundExchange(String exchangeName,
short serverId,
long proxyId) |