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

Class SessionAddMetaDataMessageV2

java.lang.Object

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

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

All Implemented Interfaces:

Packet

Direct Known Subclasses:

SessionUniqueAddMetaDataMessage

public class SessionAddMetaDataMessageV2
extends PacketImpl

A SessionAddMetaDataMessage This packet replaces SessionAddMetaDataMessage

Author:

Clebert Suconic

Field Summary

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

Modifier	Constructor and Description
	SessionAddMetaDataMessageV2()
protected	SessionAddMetaDataMessageV2(byte packetCode)
protected	SessionAddMetaDataMessageV2(byte packetCode, String k, String d)
	SessionAddMetaDataMessageV2(String k, String d)
	SessionAddMetaDataMessageV2(String k, String d, boolean requiresConfirmation)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
String	getData()
String	getKey()
boolean	isRequiresConfirmations() returns true if a confirmation should be sent on receipt of this packet.

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

decode, encode, equals, getChannelID, getPacketSize, getParentString, getType, isAsyncExec, isResponse, nullableStringEncodeSize, setChannelID, stringEncodeSize, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionAddMetaDataMessageV2

public SessionAddMetaDataMessageV2()

SessionAddMetaDataMessageV2

protected SessionAddMetaDataMessageV2(byte packetCode)

SessionAddMetaDataMessageV2

public SessionAddMetaDataMessageV2(String k,
                           String d)

SessionAddMetaDataMessageV2

protected SessionAddMetaDataMessageV2(byte packetCode,
                           String k,
                           String d)

SessionAddMetaDataMessageV2

public SessionAddMetaDataMessageV2(String k,
                           String d,
                           boolean requiresConfirmation)

Method Detail

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class PacketImpl

isRequiresConfirmations

public final boolean isRequiresConfirmations()

Description copied from interface: Packet

returns true if a confirmation should be sent on receipt of this packet.

Specified by:

isRequiresConfirmations in interface Packet

Overrides:

isRequiresConfirmations in class PacketImpl

Returns:

true if confirmation is required

getKey

public String getKey()

getData

public String getData()