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

Class SessionSendMessage

java.lang.Object

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

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

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

All Implemented Interfaces:

Packet

public class SessionSendMessage
extends MessagePacket

Author:

Tim Fox

Field Summary

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

message

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, DISCONNECT_CONSUMER, 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
SessionSendMessage(MessageInternal message)
SessionSendMessage(MessageInternal message, boolean requiresResponse, SendAcknowledgementHandler handler)

Method Summary

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
HornetQBuffer	encode(RemotingConnection connection) Encodes the packet and returns a HornetQBuffer containing the data
boolean	equals(Object obj)
SendAcknowledgementHandler	getHandler()
int	hashCode()
boolean	isRequiresResponse()

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

getMessage

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

decode, encodeRest, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionSendMessage

public SessionSendMessage(MessageInternal message,
                          boolean requiresResponse,
                          SendAcknowledgementHandler handler)

SessionSendMessage

public SessionSendMessage(MessageInternal message)

Method Detail

isRequiresResponse

public boolean isRequiresResponse()

getHandler

public SendAcknowledgementHandler getHandler()

encode

public HornetQBuffer encode(RemotingConnection connection)

Description copied from interface: Packet

Encodes the packet and returns a HornetQBuffer containing the data

Specified by:

encode in interface Packet

Overrides:

encode in class PacketImpl

Parameters:

connection - the connection

Returns:

the buffer to encode to

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class PacketImpl

hashCode

public int hashCode()

Overrides:

hashCode in class PacketImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl