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 |
Proxy.basicPublish(PublishRequest publishRequest) |
static void |
StubAgentIn.basicPublish(PublishRequest publishRequest,
short serverId,
long proxyId) |
static void |
StubLocal.basicPublish(PublishRequest publishRequest,
short serverId,
long proxyId) |
protected void |
IExchange.checkPublication(boolean mandatory) |
private void |
Proxy.doCancel(String consumerTag,
int channelNumber,
QueueShell queueShell) |
void |
FanoutExchange.doPublish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
void |
HeadersExchange.doPublish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
void |
TopicExchange.doPublish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
abstract void |
IExchange.doPublish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
void |
DirectExchange.doPublish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
static void |
StubAgentIn.exchangeDeclare(AMQP.Exchange.Declare exchangeDeclare) |
void |
Proxy.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) |
void |
IExchange.publish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
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) |
void |
Proxy.queueUnbind(AMQP.Queue.Unbind queueUnbind) |
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) |
void |
FanoutExchange.unbind(String queueName,
String routingKey,
Map<String,Object> arguments) |
void |
HeadersExchange.unbind(String queueName,
String routingKey,
Map<String,Object> arguments) |
void |
TopicExchange.unbind(String queueName,
String routingKey,
Map<String,Object> arguments) |
abstract void |
IExchange.unbind(String queueName,
String routingKey,
Map<String,Object> arguments) |
void |
DirectExchange.unbind(String queueName,
String routingKey,
Map<String,Object> arguments) |