public class ProtonServerMessage extends Object implements org.apache.qpid.proton.message.ProtonJMessage
Constructor and Description |
---|
ProtonServerMessage() |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
int |
decode(byte[] data,
int offset,
int length) |
void |
decode(ByteBuffer buffer)
This will decode a ByteBuffer tha represents the entire message.
|
int |
encode(byte[] data,
int offset,
int length) |
void |
encode(ByteBuffer buffer) |
int |
encode(org.apache.qpid.proton.codec.WritableBuffer writableBuffer) |
int |
encode2(byte[] data,
int offset,
int length) |
String |
getAddress() |
org.apache.qpid.proton.amqp.messaging.ApplicationProperties |
getApplicationProperties() |
org.apache.qpid.proton.amqp.messaging.Section |
getBody() |
String |
getContentEncoding() |
String |
getContentType() |
Object |
getCorrelationId() |
long |
getCreationTime() |
org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations |
getDeliveryAnnotations() |
long |
getDeliveryCount() |
org.apache.qpid.proton.message.MessageError |
getError() |
long |
getExpiryTime() |
org.apache.qpid.proton.amqp.messaging.Footer |
getFooter() |
String |
getGroupId() |
long |
getGroupSequence() |
org.apache.qpid.proton.amqp.messaging.Header |
getHeader() |
org.apache.qpid.proton.amqp.messaging.MessageAnnotations |
getMessageAnnotations() |
Object |
getMessageId() |
short |
getPriority() |
org.apache.qpid.proton.amqp.messaging.Properties |
getProperties() |
String |
getReplyTo() |
String |
getReplyToGroupId() |
String |
getSubject() |
long |
getTtl() |
byte[] |
getUserId() |
boolean |
isDurable() |
boolean |
isFirstAcquirer() |
void |
setAddress(String to) |
void |
setApplicationProperties(org.apache.qpid.proton.amqp.messaging.ApplicationProperties applicationProperties) |
void |
setBody(org.apache.qpid.proton.amqp.messaging.Section body) |
void |
setContentEncoding(String contentEncoding) |
void |
setContentType(String contentType) |
void |
setCorrelationId(Object correlationId) |
void |
setCreationTime(long creationTime) |
void |
setDeliveryAnnotations(org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations deliveryAnnotations) |
void |
setDeliveryCount(long deliveryCount) |
void |
setDurable(boolean durable) |
void |
setExpiryTime(long absoluteExpiryTime) |
void |
setFirstAcquirer(boolean firstAcquirer) |
void |
setFooter(org.apache.qpid.proton.amqp.messaging.Footer footer) |
void |
setGroupId(String groupId) |
void |
setGroupSequence(long groupSequence) |
void |
setHeader(org.apache.qpid.proton.amqp.messaging.Header header) |
void |
setMessageAnnotations(org.apache.qpid.proton.amqp.messaging.MessageAnnotations messageAnnotations) |
void |
setMessageId(Object messageId) |
void |
setPriority(short priority) |
void |
setProperties(org.apache.qpid.proton.amqp.messaging.Properties properties) |
void |
setReplyTo(String replyTo) |
void |
setReplyToGroupId(String replyToGroupId) |
void |
setSubject(String subject) |
void |
setTtl(long ttl) |
void |
setUserId(byte[] userId) |
public void decode(ByteBuffer buffer)
buffer
- a limited buffer for the messagepublic void encode(ByteBuffer buffer)
public int encode(org.apache.qpid.proton.codec.WritableBuffer writableBuffer)
encode
in interface org.apache.qpid.proton.message.ProtonJMessage
public boolean isDurable()
isDurable
in interface org.apache.qpid.proton.message.Message
public long getDeliveryCount()
getDeliveryCount
in interface org.apache.qpid.proton.message.Message
public short getPriority()
getPriority
in interface org.apache.qpid.proton.message.Message
public boolean isFirstAcquirer()
isFirstAcquirer
in interface org.apache.qpid.proton.message.Message
public long getTtl()
getTtl
in interface org.apache.qpid.proton.message.Message
public void setDurable(boolean durable)
setDurable
in interface org.apache.qpid.proton.message.Message
public void setTtl(long ttl)
setTtl
in interface org.apache.qpid.proton.message.Message
public void setDeliveryCount(long deliveryCount)
setDeliveryCount
in interface org.apache.qpid.proton.message.Message
public void setFirstAcquirer(boolean firstAcquirer)
setFirstAcquirer
in interface org.apache.qpid.proton.message.Message
public void setPriority(short priority)
setPriority
in interface org.apache.qpid.proton.message.Message
public Object getMessageId()
getMessageId
in interface org.apache.qpid.proton.message.Message
public long getGroupSequence()
getGroupSequence
in interface org.apache.qpid.proton.message.Message
public String getReplyToGroupId()
getReplyToGroupId
in interface org.apache.qpid.proton.message.Message
public long getCreationTime()
getCreationTime
in interface org.apache.qpid.proton.message.Message
public String getAddress()
getAddress
in interface org.apache.qpid.proton.message.Message
public byte[] getUserId()
getUserId
in interface org.apache.qpid.proton.message.Message
public String getReplyTo()
getReplyTo
in interface org.apache.qpid.proton.message.Message
public String getGroupId()
getGroupId
in interface org.apache.qpid.proton.message.Message
public String getContentType()
getContentType
in interface org.apache.qpid.proton.message.Message
public long getExpiryTime()
getExpiryTime
in interface org.apache.qpid.proton.message.Message
public Object getCorrelationId()
getCorrelationId
in interface org.apache.qpid.proton.message.Message
public String getContentEncoding()
getContentEncoding
in interface org.apache.qpid.proton.message.Message
public String getSubject()
getSubject
in interface org.apache.qpid.proton.message.Message
public void setGroupSequence(long groupSequence)
setGroupSequence
in interface org.apache.qpid.proton.message.Message
public void setUserId(byte[] userId)
setUserId
in interface org.apache.qpid.proton.message.Message
public void setCreationTime(long creationTime)
setCreationTime
in interface org.apache.qpid.proton.message.Message
public void setSubject(String subject)
setSubject
in interface org.apache.qpid.proton.message.Message
public void setGroupId(String groupId)
setGroupId
in interface org.apache.qpid.proton.message.Message
public void setAddress(String to)
setAddress
in interface org.apache.qpid.proton.message.Message
public void setExpiryTime(long absoluteExpiryTime)
setExpiryTime
in interface org.apache.qpid.proton.message.Message
public void setReplyToGroupId(String replyToGroupId)
setReplyToGroupId
in interface org.apache.qpid.proton.message.Message
public void setContentEncoding(String contentEncoding)
setContentEncoding
in interface org.apache.qpid.proton.message.Message
public void setContentType(String contentType)
setContentType
in interface org.apache.qpid.proton.message.Message
public void setReplyTo(String replyTo)
setReplyTo
in interface org.apache.qpid.proton.message.Message
public void setCorrelationId(Object correlationId)
setCorrelationId
in interface org.apache.qpid.proton.message.Message
public void setMessageId(Object messageId)
setMessageId
in interface org.apache.qpid.proton.message.Message
public org.apache.qpid.proton.amqp.messaging.Header getHeader()
getHeader
in interface org.apache.qpid.proton.message.Message
public org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations getDeliveryAnnotations()
getDeliveryAnnotations
in interface org.apache.qpid.proton.message.Message
public org.apache.qpid.proton.amqp.messaging.MessageAnnotations getMessageAnnotations()
getMessageAnnotations
in interface org.apache.qpid.proton.message.Message
public org.apache.qpid.proton.amqp.messaging.Properties getProperties()
getProperties
in interface org.apache.qpid.proton.message.Message
public org.apache.qpid.proton.amqp.messaging.ApplicationProperties getApplicationProperties()
getApplicationProperties
in interface org.apache.qpid.proton.message.Message
public org.apache.qpid.proton.amqp.messaging.Section getBody()
getBody
in interface org.apache.qpid.proton.message.Message
public org.apache.qpid.proton.amqp.messaging.Footer getFooter()
getFooter
in interface org.apache.qpid.proton.message.Message
public void setHeader(org.apache.qpid.proton.amqp.messaging.Header header)
setHeader
in interface org.apache.qpid.proton.message.Message
public void setDeliveryAnnotations(org.apache.qpid.proton.amqp.messaging.DeliveryAnnotations deliveryAnnotations)
setDeliveryAnnotations
in interface org.apache.qpid.proton.message.Message
public void setMessageAnnotations(org.apache.qpid.proton.amqp.messaging.MessageAnnotations messageAnnotations)
setMessageAnnotations
in interface org.apache.qpid.proton.message.Message
public void setProperties(org.apache.qpid.proton.amqp.messaging.Properties properties)
setProperties
in interface org.apache.qpid.proton.message.Message
public void setApplicationProperties(org.apache.qpid.proton.amqp.messaging.ApplicationProperties applicationProperties)
setApplicationProperties
in interface org.apache.qpid.proton.message.Message
public void setBody(org.apache.qpid.proton.amqp.messaging.Section body)
setBody
in interface org.apache.qpid.proton.message.Message
public void setFooter(org.apache.qpid.proton.amqp.messaging.Footer footer)
setFooter
in interface org.apache.qpid.proton.message.Message
public int decode(byte[] data, int offset, int length)
decode
in interface org.apache.qpid.proton.message.Message
public int encode(byte[] data, int offset, int length)
encode
in interface org.apache.qpid.proton.message.Message
public void clear()
clear
in interface org.apache.qpid.proton.message.Message
public org.apache.qpid.proton.message.MessageError getError()
getError
in interface org.apache.qpid.proton.message.Message
public int encode2(byte[] data, int offset, int length)
encode2
in interface org.apache.qpid.proton.message.ProtonJMessage
Copyright © 2016 The Apache Software Foundation. All rights reserved.