com.caucho.amqp.io
Class FrameTransfer

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

public class FrameTransfer
extends AmqpAbstractFrame

AMQP session-begin frame


Field Summary
static int CODE
           
 
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
FrameTransfer()
           
 
Method Summary
 FrameTransfer createInstance()
           
 long getDeliveryId()
           
 DeliveryState getDeliveryState()
           
 byte[] getDeliveryTag()
           
 long getDescriptorCode()
           
 int getHandle()
           
 int getMessageFormat()
           
 FrameAttach.ReceiverSettleMode getReceiverSettleMode()
           
 void invoke(AmqpReader ain, AmqpFrameHandler handler)
           
 boolean isAborted()
           
 boolean isBatchable()
           
 boolean isMore()
           
 boolean isResume()
           
 boolean isSettled()
           
 void readBody(AmqpReader in, int count)
           
 void setDeliveryId(long deliveryId)
           
 void setHandle(int handle)
           
 void setSettled(boolean isSettled)
           
 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
 

Field Detail

CODE

public static final int CODE
See Also:
Constant Field Values
Constructor Detail

FrameTransfer

public FrameTransfer()
Method Detail

getHandle

public int getHandle()

setHandle

public void setHandle(int handle)

getDeliveryId

public long getDeliveryId()

setDeliveryId

public void setDeliveryId(long deliveryId)

getDeliveryTag

public byte[] getDeliveryTag()

getMessageFormat

public int getMessageFormat()

isSettled

public boolean isSettled()

setSettled

public void setSettled(boolean isSettled)

isMore

public boolean isMore()

getReceiverSettleMode

public FrameAttach.ReceiverSettleMode getReceiverSettleMode()

getDeliveryState

public DeliveryState getDeliveryState()

isResume

public boolean isResume()

isAborted

public boolean isAborted()

isBatchable

public boolean isBatchable()

getDescriptorCode

public long getDescriptorCode()
Specified by:
getDescriptorCode in class AmqpAbstractComposite

createInstance

public FrameTransfer createInstance()
Overrides:
createInstance in class AmqpAbstractPacket

invoke

public void invoke(AmqpReader ain,
                   AmqpFrameHandler handler)
            throws java.io.IOException
Overrides:
invoke in class AmqpAbstractFrame
Throws:
java.io.IOException

writeBody

public int writeBody(AmqpWriter out)
              throws java.io.IOException
Specified by:
writeBody in class AmqpAbstractComposite
Throws:
java.io.IOException

readBody

public void readBody(AmqpReader in,
                     int count)
              throws java.io.IOException
Specified by:
readBody in class AmqpAbstractComposite
Throws:
java.io.IOException