com.caucho.amqp.io
Class MessageProperties

java.lang.Object
  extended by com.caucho.amqp.io.AmqpAbstractPacket
      extended by com.caucho.amqp.io.AmqpAbstractComposite
          extended by com.caucho.amqp.io.MessageProperties
All Implemented Interfaces:
AmqpConstants

public final class MessageProperties
extends AmqpAbstractComposite

The message properties header.


Field Summary
 
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
 
Constructor Summary
MessageProperties()
           
 
Method Summary
 MessageProperties createInstance()
           
 java.lang.String getContentEncoding()
           
 java.lang.String getContentType()
           
 java.lang.Object getCorrelationId()
           
 long getCreationTime()
           
 long getDescriptorCode()
           
 long getExpiryTime()
           
 java.lang.String getGroupId()
           
 long getGroupSequence()
           
 java.lang.Object getMessageId()
           
 java.lang.String getReplyTo()
           
 java.lang.String getReplyToGroupId()
           
 java.lang.String getSubject()
           
 java.lang.String getTo()
           
 java.lang.String getUserId()
           
 void readBody(AmqpReader in, int count)
           
 void setContentEncoding(java.lang.String contentEncoding)
           
 void setContentType(java.lang.String contentType)
           
 void setCorrelationId(java.lang.Object correlationId)
           
 void setCreationTime(long creationTime)
           
 void setExpiryTime(long expiryTime)
           
 void setGroupId(java.lang.String groupId)
           
 void setGroupSequence(long seq)
           
 void setMessageId(java.lang.Object messageId)
           
 void setReplyTo(java.lang.String replyTo)
           
 void setReplyToGroupId(java.lang.String replyToGroupId)
           
 void setSubject(java.lang.String subject)
           
 void setTo(java.lang.String to)
           
 void setUserId(java.lang.String userId)
           
 int writeBody(AmqpWriter out)
           
 
Methods inherited from class com.caucho.amqp.io.AmqpAbstractComposite
read, readValue, write
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MessageProperties

public MessageProperties()
Method Detail

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