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

Version:

$Revision$

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

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

Method Summary

Methods

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

SessionSendMessage

public SessionSendMessage(MessageInternal message,
                  boolean requiresResponse)

SessionSendMessage

public SessionSendMessage()

Method Detail

isRequiresResponse

public boolean isRequiresResponse()

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