Package | Description |
---|---|
org.ow2.joram.mom.amqp | |
org.ow2.joram.mom.amqp.marshalling | |
org.ow2.joram.mom.amqp.structures |
Modifier and Type | Field and Description |
---|---|
private AMQP.Basic.BasicProperties |
PublishRequest.header |
(package private) AMQP.Basic.BasicProperties |
Message.properties |
Modifier and Type | Method and Description |
---|---|
AMQP.Basic.BasicProperties |
PublishRequest.getHeader() |
Modifier and Type | Method and Description |
---|---|
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) |
void |
IExchange.publish(String routingKey,
boolean mandatory,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
protected void |
IExchange.publishToQueue(String queueName,
String routingKey,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
void |
PublishRequest.setHeader(AMQP.Basic.BasicProperties header,
long bodySize)
set the header content.
|
Constructor and Description |
---|
Message(String exchange,
String routingKey,
AMQP.Basic.BasicProperties properties,
byte[] body,
long deliveryTag,
boolean redelivered) |
Modifier and Type | Field and Description |
---|---|
private AMQP.Basic.BasicProperties |
MarshallingHeader.basicProperties |
Modifier and Type | Method and Description |
---|---|
AMQP.Basic.BasicProperties |
MarshallingHeader.getBasicProperties() |
Modifier and Type | Method and Description |
---|---|
static Frame |
MarshallingHeader.toFrame(long bodySize,
AMQP.Basic.BasicProperties basicProperties,
int channelNumber) |
Modifier and Type | Field and Description |
---|---|
AMQP.Basic.BasicProperties |
GetResponse.properties |
private AMQP.Basic.BasicProperties |
PublishToQueue.properties |
AMQP.Basic.BasicProperties |
Returned.properties |
AMQP.Basic.BasicProperties |
Deliver.properties |
Modifier and Type | Method and Description |
---|---|
AMQP.Basic.BasicProperties |
PublishToQueue.getProperties() |
Constructor and Description |
---|
Deliver(AMQP.Basic.Deliver deliver,
AMQP.Basic.BasicProperties properties,
byte[] body,
long msgId,
short serverId,
long proxyId,
String queueName,
boolean noAck) |
GetResponse(AMQP.Basic.GetOk getOk,
AMQP.Basic.BasicProperties properties,
byte[] body) |
PublishToQueue(String queueName,
String exchangeName,
String routingKey,
boolean immediate,
AMQP.Basic.BasicProperties properties,
byte[] body,
int channelNumber,
short serverId,
long proxyId) |
Returned(AMQP.Basic.Return returned,
AMQP.Basic.BasicProperties properties,
byte[] body) |
Returned(AMQP.Basic.Return returned,
AMQP.Basic.BasicProperties properties,
byte[] body,
short serverId,
long proxyId) |
Copyright © 2013 ScalAgent D.T.. All Rights Reserved.