com.caucho.amqp.io

Class MessageHeader

java.lang.Object

com.caucho.amqp.io.AmqpAbstractPacket

com.caucho.amqp.io.AmqpAbstractComposite

com.caucho.amqp.io.MessageHeader

All Implemented Interfaces:

AmqpConstants

public class MessageHeader
extends AmqpAbstractComposite

The message transport 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

Constructors

Constructor and Description
MessageHeader()

Method Summary

Modifier and Type	Method and Description
MessageHeader	createInstance()
long	getDescriptorCode()
int	getPriority()
long	getTimeToLive()
boolean	isDurable()
void	readBody(AmqpReader in, int count)
void	setDeliveryCount(int deliveryCount)
void	setDurable(boolean durable)
void	setFirstAcquirer(boolean isFirstAcquirer)
void	setPriority(int priority)
void	setTimeToLive(long timeToLive)
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

MessageHeader

public MessageHeader()

Method Detail

isDurable

public boolean isDurable()

setDurable

public void setDurable(boolean durable)

getPriority

public int getPriority()

setPriority

public void setPriority(int priority)

setDeliveryCount

public void setDeliveryCount(int deliveryCount)

setFirstAcquirer

public void setFirstAcquirer(boolean isFirstAcquirer)

setTimeToLive

public void setTimeToLive(long timeToLive)

getTimeToLive

public long getTimeToLive()

getDescriptorCode

public long getDescriptorCode()

Specified by:

getDescriptorCode in class AmqpAbstractComposite

createInstance

public MessageHeader 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