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

Class SessionSendContinuationMessage

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.SessionSendContinuationMessage

All Implemented Interfaces:

Packet

public class SessionSendContinuationMessage
extends SessionContinuationMessage

A SessionSendContinuationMessage

Author:

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

Field Summary

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
SessionSendContinuationMessage()
SessionSendContinuationMessage(MessageInternal message, byte[] body, boolean continues, boolean requiresResponse)
SessionSendContinuationMessage(MessageInternal message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
MessageInternal	getMessage()
long	getMessageBodySize()
boolean	isRequiresResponse()

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, getPacketSize, 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

Constructor Detail

SessionSendContinuationMessage

public SessionSendContinuationMessage()

SessionSendContinuationMessage

public SessionSendContinuationMessage(MessageInternal message,
                              byte[] body,
                              boolean continues,
                              boolean requiresResponse)

Parameters:

body -

continues -

requiresResponse -

SessionSendContinuationMessage

public SessionSendContinuationMessage(MessageInternal message,
                              byte[] body,
                              boolean continues,
                              boolean requiresResponse,
                              long messageBodySize)

Parameters:

body -

continues -

requiresResponse -

Method Detail

isRequiresResponse

public boolean isRequiresResponse()

Returns:

the requiresResponse

getMessageBodySize

public long getMessageBodySize()

getMessage

public MessageInternal getMessage()

Returns:

the message

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class SessionContinuationMessage

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class SessionContinuationMessage