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

Class ReplicationAddMessage

java.lang.Object

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

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

All Implemented Interfaces:

Packet

public final class ReplicationAddMessage
extends PacketImpl

A ReplicationAddMessage

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, 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
ReplicationAddMessage()
ReplicationAddMessage(byte journalID, ReplicationManager.ADD_OPERATION_TYPE operation, long id, byte journalRecordType, EncodingSupport encodingData)

Method Summary

Methods

Modifier and Type	Method and Description
void	decodeRest(HornetQBuffer buffer)
void	encodeRest(HornetQBuffer buffer)
boolean	equals(Object obj)
long	getId()
byte	getJournalID()
byte	getJournalRecordType()
ReplicationManager.ADD_OPERATION_TYPE	getRecord()
byte[]	getRecordData()
int	hashCode()

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicationAddMessage

public ReplicationAddMessage()

ReplicationAddMessage

public ReplicationAddMessage(byte journalID,
                     ReplicationManager.ADD_OPERATION_TYPE operation,
                     long id,
                     byte journalRecordType,
                     EncodingSupport encodingData)

Method Detail

encodeRest

public void encodeRest(HornetQBuffer buffer)

Overrides:

encodeRest in class PacketImpl

decodeRest

public void decodeRest(HornetQBuffer buffer)

Overrides:

decodeRest in class PacketImpl

getId

public long getId()

Returns:

the id

getJournalID

public byte getJournalID()

Returns:

the journalID

getRecord

public ReplicationManager.ADD_OPERATION_TYPE getRecord()

getJournalRecordType

public byte getJournalRecordType()

Returns:

the recordType

getRecordData

public byte[] getRecordData()

Returns:

the recordData

hashCode

public int hashCode()

Overrides:

hashCode in class PacketImpl

equals

public boolean equals(Object obj)

Overrides:

equals in class PacketImpl