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

Class SessionReceiveMessage

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

All Implemented Interfaces:

Packet

public class SessionReceiveMessage
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

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
SessionReceiveMessage()
SessionReceiveMessage(long consumerID, MessageInternal message, int deliveryCount)

Method Summary

Methods

Modifier and Type	Method and Description
void	decode(HornetQBuffer buffer) decodes the buffer into this packet
HornetQBuffer	encode(RemotingConnection connection) Encodes the packet and returns a HornetQBuffer containing the data
long	getConsumerID()
int	getDeliveryCount()

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

getMessage

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

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

SessionReceiveMessage

public SessionReceiveMessage(long consumerID,
                     MessageInternal message,
                     int deliveryCount)

SessionReceiveMessage

public SessionReceiveMessage()

Method Detail

getConsumerID

public long getConsumerID()

getDeliveryCount

public int getDeliveryCount()

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

decode

public void decode(HornetQBuffer buffer)

Description copied from interface: Packet

decodes the buffer into this packet

Specified by:

decode in interface Packet

Overrides:

decode in class PacketImpl

Parameters:

buffer - the buffer to decode from