Package | Description |
---|---|
org.ow2.joram.mom.amqp | |
org.ow2.joram.mom.amqp.marshalling |
Modifier and Type | Method and Description |
---|---|
GetResponse |
Proxy.basicGet(AMQP.Basic.Get basicGet) |
void |
Proxy.queueBind(AMQP.Queue.Bind queueBind) |
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) |
private void |
AMQPConnectionListener.tuneConnectionParameters(AMQP.Connection.TuneOk tuneOk) |
Modifier and Type | Method and Description |
---|---|
private Object[] |
AMQPInputStream.readArray() |
private Object |
AMQPInputStream.readFieldValue() |
void |
AMQP.Connection.Start.readFrom(AMQPInputStream in) |
void |
AMQP.Connection.StartOk.readFrom(AMQPInputStream in) |
void |
AMQP.Exchange.Declare.readFrom(AMQPInputStream in) |
void |
AMQP.Queue.Declare.readFrom(AMQPInputStream in) |
void |
AMQP.Queue.Bind.readFrom(AMQPInputStream in) |
void |
AMQP.Queue.Unbind.readFrom(AMQPInputStream in) |
void |
AMQP.Basic.BasicProperties.readFrom(AMQPInputStream in) |
void |
AMQP.Basic.Consume.readFrom(AMQPInputStream in) |
abstract void |
AbstractMarshallingMethod.readFrom(AMQPInputStream is) |
Map |
AMQPInputStream.readTable() |
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.