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

Class SessionReceiveLargeMessage

java.lang.Object

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

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

All Implemented Interfaces:

Packet

Direct Known Subclasses:

SessionReceiveClientLargeMessage

public class SessionReceiveLargeMessage
extends PacketImpl

A SessionReceiveLargeMessage

Author:

Clebert Suconic

Field Summary

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

Method Summary

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
boolean	equals(Object obj)
long	getConsumerID()
int	getDeliveryCount()
MessageInternal	getLargeMessage()
long	getLargeMessageSize()
int	hashCode()

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

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

SessionReceiveLargeMessage

public SessionReceiveLargeMessage(MessageInternal message)

SessionReceiveLargeMessage

public SessionReceiveLargeMessage(long consumerID,
                                  MessageInternal message,
                                  long largeMessageSize,
                                  int deliveryCount)

Method Detail

getLargeMessage

public MessageInternal getLargeMessage()

getConsumerID

public long getConsumerID()

getDeliveryCount

public int getDeliveryCount()

getLargeMessageSize

public long getLargeMessageSize()

Returns:

the largeMessageSize

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

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