org.hornetq.core.protocol.core.impl.wireformat

Class SessionReceiveContinuationMessage

java.lang.Object

org.hornetq.core.protocol.core.impl.PacketImpl

org.hornetq.core.protocol.core.impl.wireformat.SessionContinuationMessage

org.hornetq.core.protocol.core.impl.wireformat.SessionReceiveContinuationMessage

All Implemented Interfaces:

Packet

public class SessionReceiveContinuationMessage
extends SessionContinuationMessage

A SessionSendContinuationMessage

Author:

Clebert Suconic Created Dec 4, 2008 12:25:14 PM

Field Summary

Fields

Modifier and Type	Field and Description
static int	SESSION_RECEIVE_CONTINUATION_BASE_SIZE

Fields inherited from class org.hornetq.core.protocol.core.impl.wireformat.SessionContinuationMessage

body, continues, SESSION_CONTINUATION_BASE_SIZE

Fields inherited from class org.hornetq.core.protocol.core.impl.PacketImpl

channelID, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CREATE_QUEUE, CREATE_REPLICATION, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, PACKET_HEADERS_SIZE, PACKETS_CONFIRMED, PING, REATTACH_SESSION, REATTACH_SESSION_RESP, REPLICATION_APPEND, REPLICATION_APPEND_TX, REPLICATION_COMMIT_ROLLBACK, REPLICATION_COMPARE_DATA, REPLICATION_DELETE, REPLICATION_DELETE_TX, REPLICATION_LARGE_MESSAGE_BEGIN, REPLICATION_LARGE_MESSAGE_END, REPLICATION_LARGE_MESSAGE_WRITE, REPLICATION_PAGE_EVENT, REPLICATION_PAGE_WRITE, REPLICATION_PREPARE, REPLICATION_RESPONSE, REPLICATION_SYNC, SESS_ACKNOWLEDGE, SESS_ADD_METADATA, SESS_ADD_METADATA2, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_CLOSE, SESS_COMMIT, SESS_CONSUMER_CLOSE, SESS_CREATECONSUMER, SESS_EXPIRED, SESS_FLOWTOKEN, SESS_FORCE_CONSUMER_DELIVERY, SESS_INDIVIDUAL_ACKNOWLEDGE, SESS_PRODUCER_CREDITS, SESS_PRODUCER_REQUEST_CREDITS, SESS_QUEUEQUERY, SESS_QUEUEQUERY_RESP, SESS_RECEIVE_CONTINUATION, SESS_RECEIVE_LARGE_MSG, SESS_RECEIVE_MSG, SESS_ROLLBACK, SESS_SEND, SESS_SEND_CONTINUATION, SESS_SEND_LARGE, SESS_START, SESS_STOP, SESS_UNIQUE_ADD_METADATA, SESS_XA_COMMIT, SESS_XA_END, SESS_XA_FORGET, SESS_XA_GET_TIMEOUT, SESS_XA_GET_TIMEOUT_RESP, SESS_XA_INDOUBT_XIDS, SESS_XA_INDOUBT_XIDS_RESP, SESS_XA_JOIN, SESS_XA_PREPARE, SESS_XA_RESP, SESS_XA_RESUME, SESS_XA_ROLLBACK, SESS_XA_SET_TIMEOUT, SESS_XA_SET_TIMEOUT_RESP, SESS_XA_START, SESS_XA_SUSPEND, size, SUBSCRIBE_TOPOLOGY, SUBSCRIBE_TOPOLOGY_V2, type

Constructor Summary

Constructors

Constructor and Description
SessionReceiveContinuationMessage()
SessionReceiveContinuationMessage(long consumerID, byte[] body, boolean continues, boolean requiresResponse)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
long	getConsumerID()
int	getPacketSize() returns the size needed to encode this packet.

Methods inherited from class org.hornetq.core.protocol.core.impl.wireformat.SessionContinuationMessage

getBody, isContinues

Methods inherited from class org.hornetq.core.protocol.core.impl.PacketImpl

decode, encode, equals, getChannelID, getParentString, getType, isAsyncExec, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID, stringEncodeSize, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

SESSION_RECEIVE_CONTINUATION_BASE_SIZE

public static final int SESSION_RECEIVE_CONTINUATION_BASE_SIZE

See Also:

Constant Field Values

Constructor Detail

SessionReceiveContinuationMessage

public SessionReceiveContinuationMessage()

SessionReceiveContinuationMessage

public SessionReceiveContinuationMessage(long consumerID,
                                 byte[] body,
                                 boolean continues,
                                 boolean requiresResponse)

Parameters:

consumerID -

body -

continues -

requiresResponse -

Method Detail

getConsumerID

public long getConsumerID()

Returns:

the consumerID

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class SessionContinuationMessage

getPacketSize

public int getPacketSize()

Description copied from interface: Packet

returns the size needed to encode this packet.

Specified by:

getPacketSize in interface Packet

Overrides:

getPacketSize in class PacketImpl

Returns:

The size of the entire packet including headers, and extra data

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class SessionContinuationMessage