public interface MessagePropertiesFactory<T>
extends java.util.concurrent.BlockingQueue<T>
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.lang.String |
getContentEncoding() |
java.lang.String |
getContentType() |
java.lang.Object |
getCorrelationId() |
long |
getCreationTime() |
long |
getExpiryTime() |
java.lang.String |
getGroupId() |
long |
getGroupSequence() |
java.lang.Object |
getMessageId() |
int |
getPriority() |
java.lang.String |
getReplyTo() |
java.lang.String |
getReplyToGroupId() |
java.lang.String |
getSubject() |
long |
getTimeToLive() |
java.lang.String |
getTo() |
java.lang.String |
getUserId() |
boolean |
isDurable() |
boolean |
isFirstAcquirer() |
void |
setContentEncoding(java.lang.String contentEncoding) |
void |
setContentType(java.lang.String contentType) |
void |
setCorrelationId(java.lang.Object value) |
void |
setCreationTime(long value) |
void |
setDurable(boolean isDurable) |
void |
setExpiryTime(long expiryTime) |
void |
setFirstAcquirer(boolean isFirst) |
void |
setGroupId(java.lang.String value) |
void |
setGroupSequence(long value) |
void |
setMessageId(java.lang.Object messageId) |
void |
setPriority(int priority) |
void |
setReplyTo(java.lang.String replyTo) |
void |
setReplyToGroupId(java.lang.String value) |
void |
setSubject(java.lang.String subject) |
void |
setTimeToLive(long timeToLive) |
void |
setTo(java.lang.String to) |
void |
setUserId(java.lang.String userId) |
add, contains, drainTo, drainTo, offer, offer, poll, put, remainingCapacity, remove, take
void setDurable(boolean isDurable)
boolean isDurable()
void setPriority(int priority)
int getPriority()
long getTimeToLive()
void setTimeToLive(long timeToLive)
boolean isFirstAcquirer()
void setFirstAcquirer(boolean isFirst)
java.lang.Object getMessageId()
void setMessageId(java.lang.Object messageId)
java.lang.String getUserId()
void setUserId(java.lang.String userId)
java.lang.String getTo()
void setTo(java.lang.String to)
java.lang.String getSubject()
void setSubject(java.lang.String subject)
java.lang.String getReplyTo()
void setReplyTo(java.lang.String replyTo)
java.lang.Object getCorrelationId()
void setCorrelationId(java.lang.Object value)
java.lang.String getContentType()
void setContentType(java.lang.String contentType)
java.lang.String getContentEncoding()
void setContentEncoding(java.lang.String contentEncoding)
long getExpiryTime()
void setExpiryTime(long expiryTime)
long getCreationTime()
void setCreationTime(long value)
java.lang.String getGroupId()
void setGroupId(java.lang.String value)
long getGroupSequence()
void setGroupSequence(long value)
java.lang.String getReplyToGroupId()
void setReplyToGroupId(java.lang.String value)
void close()