com.caucho.amqp.io
Class MessageProperties
java.lang.Object
com.caucho.amqp.io.AmqpAbstractPacket
com.caucho.amqp.io.AmqpAbstractComposite
com.caucho.amqp.io.MessageProperties
- All Implemented Interfaces:
- AmqpConstants
public final class MessageProperties
- extends AmqpAbstractComposite
The message properties header.
Fields inherited from interface com.caucho.amqp.io.AmqpConstants |
E_ARRAY_1, E_ARRAY_4, E_BIN_1, E_BIN_4, E_BOOLEAN_1, E_BYTE_1, E_CHAR, E_DECIMAL_16, E_DECIMAL_4, E_DECIMAL_8, E_DESCRIPTOR, E_DOUBLE, E_FALSE, E_FLOAT, E_I0, E_INT_1, E_INT_4, E_L0, E_LIST_0, E_LIST_1, E_LIST_4, E_LONG_1, E_LONG_8, E_MAP_1, E_MAP_4, E_NULL, E_SHORT, E_SYMBOL_1, E_SYMBOL_4, E_TIMESTAMP, E_TRUE, E_UBYTE_1, E_UINT_1, E_UINT_4, E_ULONG_1, E_ULONG_8, E_USHORT, E_UTF8_1, E_UTF8_4, E_UUID, FT_CONN_CLOSE, FT_CONN_OPEN, FT_ERROR, FT_LINK_ATTACH, FT_LINK_DETACH, FT_LINK_FLOW, FT_MESSAGE_DISPOSITION, FT_MESSAGE_TRANSFER, FT_SESSION_END, FT_SESSION_OPEN, MIN_MAX_FRAME_SIZE, ST_MESSAGE_ACCEPTED, ST_MESSAGE_ANN, ST_MESSAGE_APP_PROPERTIES, ST_MESSAGE_DATA, ST_MESSAGE_DELIVERY_ANN, ST_MESSAGE_FOOTER, ST_MESSAGE_HEADER, ST_MESSAGE_MODIFIED, ST_MESSAGE_PROPERTIES, ST_MESSAGE_RECEIVED, ST_MESSAGE_REJECTED, ST_MESSAGE_RELEASED, ST_MESSAGE_SEQUENCE, ST_MESSAGE_SOURCE, ST_MESSAGE_TARGET, ST_MESSAGE_VALUE, ST_NODE_DELETE_ON_CLOSE, ST_NODE_DELETE_ON_NO_LINK, ST_NODE_DELETE_ON_NO_LINK_OR_MESSAGES, ST_NODE_DELETE_ON_NO_MESSAGES, ST_SASL_CHALLENGE, ST_SASL_INIT, ST_SASL_MECHANISMS, ST_SASL_OUTCOME, ST_SASL_RESPONSE, ST_XA_COORDINATOR, ST_XA_DECLARE, ST_XA_DECLARED, ST_XA_DISCHARGE, ST_XA_STATE |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MessageProperties
public MessageProperties()
getMessageId
public java.lang.Object getMessageId()
setMessageId
public void setMessageId(java.lang.Object messageId)
getUserId
public java.lang.String getUserId()
setUserId
public void setUserId(java.lang.String userId)
setTo
public void setTo(java.lang.String to)
getTo
public java.lang.String getTo()
getSubject
public java.lang.String getSubject()
setSubject
public void setSubject(java.lang.String subject)
getReplyTo
public java.lang.String getReplyTo()
setReplyTo
public void setReplyTo(java.lang.String replyTo)
getCorrelationId
public java.lang.Object getCorrelationId()
setCorrelationId
public void setCorrelationId(java.lang.Object correlationId)
getContentType
public java.lang.String getContentType()
setContentType
public void setContentType(java.lang.String contentType)
getContentEncoding
public java.lang.String getContentEncoding()
setContentEncoding
public void setContentEncoding(java.lang.String contentEncoding)
getExpiryTime
public long getExpiryTime()
setExpiryTime
public void setExpiryTime(long expiryTime)
getCreationTime
public long getCreationTime()
setCreationTime
public void setCreationTime(long creationTime)
getGroupId
public java.lang.String getGroupId()
setGroupId
public void setGroupId(java.lang.String groupId)
getGroupSequence
public long getGroupSequence()
setGroupSequence
public void setGroupSequence(long seq)
getReplyToGroupId
public java.lang.String getReplyToGroupId()
setReplyToGroupId
public void setReplyToGroupId(java.lang.String replyToGroupId)
getDescriptorCode
public long getDescriptorCode()
- Specified by:
getDescriptorCode
in class AmqpAbstractComposite
createInstance
public MessageProperties createInstance()
- Overrides:
createInstance
in class AmqpAbstractPacket
readBody
public void readBody(AmqpReader in,
int count)
throws java.io.IOException
- Specified by:
readBody
in class AmqpAbstractComposite
- Throws:
java.io.IOException
writeBody
public int writeBody(AmqpWriter out)
throws java.io.IOException
- Specified by:
writeBody
in class AmqpAbstractComposite
- Throws:
java.io.IOException