org.apache.activemq.artemis.core.protocol.core.impl.wireformat

Class SessionReceiveMessage

java.lang.Object

org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.MessagePacket

org.apache.activemq.artemis.core.protocol.core.impl.wireformat.SessionReceiveMessage

All Implemented Interfaces:

MessagePacketI, Packet

public class SessionReceiveMessage
extends MessagePacket

Field Summary

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.MessagePacket

message

Fields inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

BACKUP_REGISTRATION, BACKUP_REGISTRATION_FAILED, BACKUP_REQUEST, BACKUP_REQUEST_RESPONSE, channelID, CHECK_FOR_FAILOVER, CHECK_FOR_FAILOVER_REPLY, CLUSTER_CONNECT, CLUSTER_CONNECT_REPLY, CLUSTER_TOPOLOGY, CLUSTER_TOPOLOGY_V2, CLUSTER_TOPOLOGY_V3, CREATE_QUEUE, CREATE_SHARED_QUEUE, CREATESESSION, CREATESESSION_RESP, DELETE_QUEUE, DISCONNECT, DISCONNECT_CONSUMER, DISCONNECT_CONSUMER_KILL, DISCONNECT_V2, EXCEPTION, NODE_ANNOUNCE, NULL_RESPONSE, PACKET_HEADERS_SIZE, PACKETS_CONFIRMED, PING, QUORUM_VOTE, QUORUM_VOTE_REPLY, 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_RESPONSE_V2, REPLICATION_SCHEDULED_FAILOVER, REPLICATION_START_FINISH_SYNC, REPLICATION_SYNC_FILE, SCALEDOWN_ANNOUNCEMENT, SESS_ACKNOWLEDGE, SESS_ADD_METADATA, SESS_ADD_METADATA2, SESS_BINDINGQUERY, SESS_BINDINGQUERY_RESP, SESS_BINDINGQUERY_RESP_V2, SESS_BINDINGQUERY_RESP_V3, 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_QUEUEQUERY_RESP_V2, 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

Fields inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet

INITIAL_PACKET_SIZE

Constructor Summary

Constructors

Constructor and Description
SessionReceiveMessage(long consumerID, MessageInternal message, int deliveryCount)
SessionReceiveMessage(MessageInternal message)

Method Summary

Modifier and Type	Method and Description
void	decode(ActiveMQBuffer buffer) decodes the buffer into this packet
ActiveMQBuffer	encode(RemotingConnection connection) Encodes the packet and returns a ActiveMQBuffer containing the data
boolean	equals(Object obj)
long	getConsumerID()
int	getDeliveryCount()
int	hashCode()
String	toString()

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.wireformat.MessagePacket

getMessage, getParentString

Methods inherited from class org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl

createPacket, decodeRest, encodeRest, getChannelID, getPacketSize, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.activemq.artemis.core.protocol.core.Packet

expectedEncodeSize, release

Constructor Detail

SessionReceiveMessage

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

SessionReceiveMessage

public SessionReceiveMessage(MessageInternal message)

Method Detail

getConsumerID

public long getConsumerID()

getDeliveryCount

public int getDeliveryCount()

encode

public ActiveMQBuffer encode(RemotingConnection connection)

Description copied from interface: Packet

Encodes the packet and returns a ActiveMQBuffer 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(ActiveMQBuffer 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

hashCode

public int hashCode()

Overrides:

hashCode in class PacketImpl

toString

public String toString()

Overrides:

toString in class PacketImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl