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
Created Dec 4, 2008 12:25:14 PM

Author:

Clebert Suconic

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

BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, channelID, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CREATE_QUEUE, CREATE_SHARED_QUEUE, 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_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_SCHEDULED_FAILOVER, REPLICATION_START_FINISH_SYNC, REPLICATION_SYNC_FILE, 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_FAIL_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_FAILED, 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

Constructor Summary

Constructors

Constructor and Description
SessionSendContinuationMessage()
SessionSendContinuationMessage(MessageInternal message, byte[] body, boolean continues, boolean requiresResponse, long messageBodySize, SendAcknowledgementHandler handler)
SessionSendContinuationMessage(MessageInternal message, byte[] body, boolean continues, boolean requiresResponse, SendAcknowledgementHandler handler)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
boolean	equals(Object obj)
SendAcknowledgementHandler	getHandler()
MessageInternal	getMessage()
long	getMessageBodySize()
int	hashCode()
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, getChannelID, getPacketSize, getParentString, getType, isAsyncExec, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionSendContinuationMessage

public SessionSendContinuationMessage()

SessionSendContinuationMessage

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

Parameters:

body -

continues -

requiresResponse -

SessionSendContinuationMessage

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

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

hashCode

public int hashCode()

Overrides:

hashCode in class SessionContinuationMessage

equals

public boolean equals(Object obj)

Overrides:

equals in class SessionContinuationMessage

getHandler

public SendAcknowledgementHandler getHandler()