com.caucho.amqp.io
Class FrameAttach
java.lang.Object
com.caucho.amqp.io.AmqpAbstractPacket
com.caucho.amqp.io.AmqpAbstractComposite
com.caucho.amqp.io.AmqpAbstractFrame
com.caucho.amqp.io.FrameAttach
- All Implemented Interfaces:
- AmqpConstants
public class FrameAttach
- extends AmqpAbstractFrame
AMQP link-attach 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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
CODE
public static final int CODE
- See Also:
- Constant Field Values
FrameAttach
public FrameAttach()
getName
public java.lang.String getName()
setName
public void setName(java.lang.String name)
getHandle
public int getHandle()
setHandle
public void setHandle(int handle)
getRole
public FrameAttach.Role getRole()
setRole
public void setRole(FrameAttach.Role role)
setSenderSettleMode
public void setSenderSettleMode(FrameAttach.SenderSettleMode mode)
getSenderSettleMode
public FrameAttach.SenderSettleMode getSenderSettleMode()
setReceiverSettleMode
public void setReceiverSettleMode(FrameAttach.ReceiverSettleMode mode)
getReceiverSettleMode
public FrameAttach.ReceiverSettleMode getReceiverSettleMode()
getSource
public LinkSource getSource()
setSource
public void setSource(LinkSource source)
getTarget
public LinkTarget getTarget()
setTarget
public void setTarget(LinkTarget target)
getUnsettled
public java.util.Map<?,?> getUnsettled()
isIncompleteUnsettled
public boolean isIncompleteUnsettled()
getInitialDeliveryCount
public long getInitialDeliveryCount()
setInitialDeliveryCount
public void setInitialDeliveryCount(long deliveryCount)
getMaxMessageSize
public long getMaxMessageSize()
getOfferedCapabilities
public java.util.List<java.lang.String> getOfferedCapabilities()
getDesiredCapabilities
public java.util.List<java.lang.String> getDesiredCapabilities()
setProperties
public void setProperties(java.util.Map<java.lang.String,?> properties)
getProperties
public java.util.Map<java.lang.String,?> getProperties()
getDescriptorCode
public long getDescriptorCode()
- Specified by:
getDescriptorCode
in class AmqpAbstractComposite
createInstance
public FrameAttach createInstance()
- Overrides:
createInstance
in class AmqpAbstractPacket
invoke
public void invoke(AmqpReader ain,
AmqpFrameHandler receiver)
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
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object