private static void |
StubAgentIn.addBoundExchange(AddBoundExchange request,
short serverId,
long proxyId) |
void |
Queue.addBoundExchange(String exchange,
short serverId,
long proxyId) |
static Boolean |
StubAgentIn.basicCancel(String consumerTag,
String queueName,
int channelNumber,
short serverId,
long proxyId) |
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 |
StubLocal.basicPublish(PublishRequest publishRequest,
short serverId,
long proxyId) |
void |
Proxy.basicRecover(boolean requeue,
int channelNumber) |
static void |
StubAgentIn.basicRecover(String queueName,
List<Long> idsToRecover) |
void |
Proxy.basicReject(AMQP.Basic.Reject basicReject) |
int |
Queue.clear(short serverId,
long proxyId) |
private void |
Proxy.commitTx() |
void |
Queue.deleteQueue(String queueName,
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 |
HeadersExchange.doPublish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
void |
FanoutExchange.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 IExchange |
IExchange.loadExchange(String name) |
static Queue |
Queue.loadQueue(String name) |
private static void |
AMQPService.loads() |
void |
Queue.publish(Message msg,
boolean immediate,
short serverId,
long proxyId) |
void |
IExchange.publish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
private static void |
StubAgentIn.publishToQueue(PublishToQueue request) |
protected void |
IExchange.publishToQueue(String queueName,
String routingKey,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
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) |
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) |
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) |
static AMQP.Queue.PurgeOk |
StubAgentIn.queuePurge(AMQP.Queue.Purge queuePurge,
short serverId,
long proxyId) |
static int |
StubLocal.queuePurge(String queueName,
short serverId,
long proxyId) |
Message |
Queue.receive(boolean noAck,
short serverId,
long proxyId) |
void |
Queue.recoverMessages(List<Long> idsToRecover) |
private static void |
StubAgentIn.removeQueueBindings(RemoveQueueBindings request) |
abstract void |
IExchange.removeQueueBindings(String queueName) |
private void |
Queue.saveBoundExchange(String exchange) |
private void |
Queue.saveMessage(Message msg) |
private void |
Queue.saveQueue(Queue queue) |
void |
Proxy.txCommit(int channelNumber) |