public class MessageImpl extends Object implements ProtonJMessage
Message.Factory
DEFAULT_PRIORITY
Constructor and Description |
---|
MessageImpl()
Deprecated.
This constructor's visibility will be reduced to the default scope in a future release.
Client code outside this module should use
Message.Factory#create() instead |
MessageImpl(Header header,
DeliveryAnnotations deliveryAnnotations,
MessageAnnotations messageAnnotations,
Properties properties,
ApplicationProperties applicationProperties,
Section body,
Footer footer)
Deprecated.
This constructor's visibility will be reduced to the default scope in a future release.
Client code outside this module should instead use
Message.Factory#create(Header, DeliveryAnnotations, MessageAnnotations, Properties, ApplicationProperties, Section, Footer) |
Modifier and Type | Method and Description |
---|---|
void |
clear() |
int |
decode(byte[] data,
int offset,
int length)
TODO describe what happens if the data does not represent a complete message.
|
void |
decode(ByteBuffer buffer) |
int |
encode(byte[] data,
int offset,
int length)
Encodes up to
length bytes of the message into the provided byte array,
starting at position offset . |
int |
encode(WritableBuffer buffer) |
int |
encode2(byte[] data,
int offset,
int length) |
String |
getAddress() |
ApplicationProperties |
getApplicationProperties() |
Section |
getBody() |
String |
getContentEncoding() |
String |
getContentType() |
Object |
getCorrelationId() |
long |
getCreationTime() |
DeliveryAnnotations |
getDeliveryAnnotations() |
long |
getDeliveryCount() |
MessageError |
getError() |
long |
getExpiryTime() |
Footer |
getFooter() |
String |
getGroupId() |
long |
getGroupSequence() |
Header |
getHeader() |
MessageAnnotations |
getMessageAnnotations() |
Object |
getMessageId() |
short |
getPriority() |
Properties |
getProperties() |
String |
getReplyTo() |
String |
getReplyToGroupId() |
String |
getSubject() |
long |
getTtl() |
byte[] |
getUserId() |
boolean |
isDurable() |
boolean |
isFirstAcquirer() |
void |
setAddress(String to) |
void |
setApplicationProperties(ApplicationProperties applicationProperties) |
void |
setBody(Section body) |
void |
setContentEncoding(String contentEncoding) |
void |
setContentType(String contentType) |
void |
setCorrelationId(Object correlationId) |
void |
setCreationTime(long creationTime) |
void |
setDeliveryAnnotations(DeliveryAnnotations deliveryAnnotations) |
void |
setDeliveryCount(long deliveryCount) |
void |
setDurable(boolean durable) |
void |
setExpiryTime(long absoluteExpiryTime) |
void |
setFirstAcquirer(boolean firstAcquirer) |
void |
setFooter(Footer footer) |
void |
setGroupId(String groupId) |
void |
setGroupSequence(long groupSequence) |
void |
setHeader(Header header) |
void |
setMessageAnnotations(MessageAnnotations messageAnnotations) |
void |
setMessageId(Object messageId) |
void |
setPriority(short priority) |
void |
setProperties(Properties properties) |
void |
setReplyTo(String replyTo) |
void |
setReplyToGroupId(String replyToGroupId) |
void |
setSubject(String subject) |
void |
setTtl(long ttl) |
void |
setUserId(byte[] userId) |
String |
toString() |
@Deprecated public MessageImpl()
Message.Factory#create()
instead@Deprecated public MessageImpl(Header header, DeliveryAnnotations deliveryAnnotations, MessageAnnotations messageAnnotations, Properties properties, ApplicationProperties applicationProperties, Section body, Footer footer)
Message.Factory#create(Header, DeliveryAnnotations, MessageAnnotations, Properties, ApplicationProperties, Section, Footer)
public long getDeliveryCount()
getDeliveryCount
in interface Message
public short getPriority()
getPriority
in interface Message
public boolean isFirstAcquirer()
isFirstAcquirer
in interface Message
public void setDurable(boolean durable)
setDurable
in interface Message
public void setDeliveryCount(long deliveryCount)
setDeliveryCount
in interface Message
public void setFirstAcquirer(boolean firstAcquirer)
setFirstAcquirer
in interface Message
public void setPriority(short priority)
setPriority
in interface Message
public Object getMessageId()
getMessageId
in interface Message
public long getGroupSequence()
getGroupSequence
in interface Message
public String getReplyToGroupId()
getReplyToGroupId
in interface Message
public long getCreationTime()
getCreationTime
in interface Message
public String getAddress()
getAddress
in interface Message
public String getReplyTo()
getReplyTo
in interface Message
public String getGroupId()
getGroupId
in interface Message
public String getContentType()
getContentType
in interface Message
public long getExpiryTime()
getExpiryTime
in interface Message
public Object getCorrelationId()
getCorrelationId
in interface Message
public String getContentEncoding()
getContentEncoding
in interface Message
public String getSubject()
getSubject
in interface Message
public void setGroupSequence(long groupSequence)
setGroupSequence
in interface Message
public void setCreationTime(long creationTime)
setCreationTime
in interface Message
public void setSubject(String subject)
setSubject
in interface Message
public void setGroupId(String groupId)
setGroupId
in interface Message
public void setAddress(String to)
setAddress
in interface Message
public void setExpiryTime(long absoluteExpiryTime)
setExpiryTime
in interface Message
public void setReplyToGroupId(String replyToGroupId)
setReplyToGroupId
in interface Message
public void setContentEncoding(String contentEncoding)
setContentEncoding
in interface Message
public void setContentType(String contentType)
setContentType
in interface Message
public void setReplyTo(String replyTo)
setReplyTo
in interface Message
public void setCorrelationId(Object correlationId)
setCorrelationId
in interface Message
public void setMessageId(Object messageId)
setMessageId
in interface Message
public DeliveryAnnotations getDeliveryAnnotations()
getDeliveryAnnotations
in interface Message
public MessageAnnotations getMessageAnnotations()
getMessageAnnotations
in interface Message
public Properties getProperties()
getProperties
in interface Message
public ApplicationProperties getApplicationProperties()
getApplicationProperties
in interface Message
public void setDeliveryAnnotations(DeliveryAnnotations deliveryAnnotations)
setDeliveryAnnotations
in interface Message
public void setMessageAnnotations(MessageAnnotations messageAnnotations)
setMessageAnnotations
in interface Message
public void setProperties(Properties properties)
setProperties
in interface Message
public void setApplicationProperties(ApplicationProperties applicationProperties)
setApplicationProperties
in interface Message
public int decode(byte[] data, int offset, int length)
Message
public void decode(ByteBuffer buffer)
public int encode(byte[] data, int offset, int length)
Message
length
bytes of the message into the provided byte array,
starting at position offset
.
TODO describe what happens if length is smaller than the encoded form, Currently
Proton-J throws an exception. What does Proton-C do?public int encode2(byte[] data, int offset, int length)
encode2
in interface ProtonJMessage
public int encode(WritableBuffer buffer)
encode
in interface ProtonJMessage
public MessageError getError()
Copyright © 2016 The Apache Software Foundation. All rights reserved.