Package | Description |
---|---|
org.apache.qpid.client.message | |
org.apache.qpid.client.protocol | |
org.apache.qpid.framing | |
org.apache.qpid.protocol | |
org.apache.qpid.server.protocol.v0_8 |
Modifier and Type | Method and Description |
---|---|
ContentHeaderBody |
UnprocessedMessage_0_8.getContentHeader() |
Modifier and Type | Method and Description |
---|---|
protected AbstractJMSMessage |
AbstractJMSMessageFactory.create08MessageWithBody(long messageNbr,
ContentHeaderBody contentHeader,
String exchange,
String routingKey,
List bodies,
AMQSession_0_8.DestinationCache<AMQQueue> queueDestinationCache,
AMQSession_0_8.DestinationCache<AMQTopic> topicDestinationCache,
int addressType) |
AbstractJMSMessage |
AbstractJMSMessageFactory.createMessage(long messageNbr,
boolean redelivered,
ContentHeaderBody contentHeader,
String exchange,
String routingKey,
List bodies,
AMQSession_0_8.DestinationCache<AMQQueue> queueDestinationCache,
AMQSession_0_8.DestinationCache<AMQTopic> topicDestinationCache,
int addressType) |
AbstractJMSMessage |
MessageFactoryRegistry.createMessage(long deliveryTag,
boolean redelivered,
String exchange,
String routingKey,
ContentHeaderBody contentHeader,
List bodies,
AMQSession_0_8.DestinationCache<AMQQueue> queueDestinationCache,
AMQSession_0_8.DestinationCache<AMQTopic> topicDestinationCache,
int addressType)
Create a message.
|
void |
UnprocessedMessage_0_8.setContentHeader(ContentHeaderBody contentHeader) |
Modifier and Type | Method and Description |
---|---|
void |
AMQProtocolSession.contentHeaderReceived(int channelId,
ContentHeaderBody contentHeader) |
Modifier and Type | Method and Description |
---|---|
static ContentHeaderBody |
ContentHeaderBody.createFromBuffer(MarkableDataInput buffer,
long size)
Helper method that is used currently by the persistence layer.
|
Modifier and Type | Method and Description |
---|---|
void |
AMQVersionAwareProtocolSession.contentHeaderReceived(int channelId,
ContentHeaderBody body) |
Modifier and Type | Method and Description |
---|---|
ContentHeaderBody |
IncomingMessage.getContentHeader() |
ContentHeaderBody |
AMQMessage.getContentHeaderBody() |
ContentHeaderBody |
MessageMetaData.getContentHeaderBody() |
Modifier and Type | Method and Description |
---|---|
void |
AMQChannel.publishContentHeader(ContentHeaderBody contentHeaderBody) |
void |
IncomingMessage.setContentHeaderBody(ContentHeaderBody contentHeaderBody) |
void |
ProtocolOutputConverterImpl.writeReturn(MessagePublishInfo messagePublishInfo,
ContentHeaderBody header,
MessageContentSource message,
int channelId,
int replyCode,
AMQShortString replyText) |
void |
ProtocolOutputConverter.writeReturn(MessagePublishInfo messagePublishInfo,
ContentHeaderBody header,
MessageContentSource msgContent,
int channelId,
int replyCode,
AMQShortString replyText) |
Constructor and Description |
---|
MessageMetaData(MessagePublishInfo publishBody,
ContentHeaderBody contentHeaderBody) |
MessageMetaData(MessagePublishInfo publishBody,
ContentHeaderBody contentHeaderBody,
long arrivalTime) |
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.