public interface Message
Message.Factory
.Modifier and Type | Interface and Description |
---|---|
static class |
Message.Factory |
Modifier and Type | Field and Description |
---|---|
static short |
DEFAULT_PRIORITY |
static final short DEFAULT_PRIORITY
boolean isDurable()
long getDeliveryCount()
short getPriority()
boolean isFirstAcquirer()
long getTtl()
void setDurable(boolean durable)
void setTtl(long ttl)
void setDeliveryCount(long deliveryCount)
void setFirstAcquirer(boolean firstAcquirer)
void setPriority(short priority)
Object getMessageId()
long getGroupSequence()
String getReplyToGroupId()
long getCreationTime()
String getAddress()
byte[] getUserId()
String getReplyTo()
String getGroupId()
String getContentType()
long getExpiryTime()
Object getCorrelationId()
String getContentEncoding()
String getSubject()
void setGroupSequence(long groupSequence)
void setUserId(byte[] userId)
void setCreationTime(long creationTime)
void setSubject(String subject)
void setGroupId(String groupId)
void setAddress(String to)
void setExpiryTime(long absoluteExpiryTime)
void setReplyToGroupId(String replyToGroupId)
void setContentEncoding(String contentEncoding)
void setContentType(String contentType)
void setReplyTo(String replyTo)
void setCorrelationId(Object correlationId)
void setMessageId(Object messageId)
Header getHeader()
DeliveryAnnotations getDeliveryAnnotations()
MessageAnnotations getMessageAnnotations()
Properties getProperties()
ApplicationProperties getApplicationProperties()
Section getBody()
Footer getFooter()
void setHeader(Header header)
void setDeliveryAnnotations(DeliveryAnnotations deliveryAnnotations)
void setMessageAnnotations(MessageAnnotations messageAnnotations)
void setProperties(Properties properties)
void setApplicationProperties(ApplicationProperties applicationProperties)
void setBody(Section body)
void setFooter(Footer footer)
int decode(byte[] data, int offset, int length)
int encode(byte[] data, int offset, int length)
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?void clear()
MessageError getError()
Copyright © 2016 The Apache Software Foundation. All rights reserved.