public final class ReplicationSyncFileMessage extends PacketImpl
SequentialFile
s to a backup server. The ReplicationSyncFileMessage.FileType
controls
which extra information is sent.Modifier and Type | Class and Description |
---|---|
static class |
ReplicationSyncFileMessage.FileType |
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
INITIAL_PACKET_SIZE
Constructor and Description |
---|
ReplicationSyncFileMessage() |
ReplicationSyncFileMessage(AbstractJournalStorageManager.JournalContent content,
SimpleString storeName,
long id,
int size,
io.netty.buffer.ByteBuf buffer) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(ActiveMQBuffer buffer) |
void |
encodeRest(ActiveMQBuffer buffer) |
boolean |
equals(Object obj) |
int |
expectedEncodeSize() |
byte[] |
getData() |
ReplicationSyncFileMessage.FileType |
getFileType() |
long |
getId() |
AbstractJournalStorageManager.JournalContent |
getJournalContent() |
SimpleString |
getPageStore() |
int |
hashCode() |
void |
release() |
String |
toString() |
createPacket, decode, encode, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID
public ReplicationSyncFileMessage()
public ReplicationSyncFileMessage(AbstractJournalStorageManager.JournalContent content, SimpleString storeName, long id, int size, io.netty.buffer.ByteBuf buffer)
public int expectedEncodeSize()
public void encodeRest(ActiveMQBuffer buffer)
encodeRest
in class PacketImpl
public void release()
public void decodeRest(ActiveMQBuffer buffer)
decodeRest
in class PacketImpl
public long getId()
public AbstractJournalStorageManager.JournalContent getJournalContent()
public byte[] getData()
public ReplicationSyncFileMessage.FileType getFileType()
public SimpleString getPageStore()
public int hashCode()
hashCode
in class PacketImpl
public boolean equals(Object obj)
equals
in class PacketImpl
public String toString()
toString
in class PacketImpl
Copyright © 2018 The Apache Software Foundation. All Rights Reserved.