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) |
private static void |
StubLocal.checkName(String name) |
void |
Queue.consume(DeliveryListener proxy,
int channelId,
String consumerTag,
boolean exclusiveConsumer,
boolean noAck,
boolean noLocal,
short serverId,
long proxyId) |
protected void |
IExchange.deleteExchange() |
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) |
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) |