public class ReplicationStartSyncMessage extends PacketImpl
At start, it sends all fileIDs used in a given journal live server to the backup, so the backup can reserve those IDs.
Modifier and Type | Class and Description |
---|---|
static class |
ReplicationStartSyncMessage.SyncDataType |
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 and Description |
---|
ReplicationStartSyncMessage() |
ReplicationStartSyncMessage(JournalFile[] datafiles,
JournalStorageManager.JournalContent contentType,
String nodeID,
boolean allowsAutoFailBack) |
ReplicationStartSyncMessage(List<Long> filenames) |
ReplicationStartSyncMessage(String nodeID) |
Modifier and Type | Method and Description |
---|---|
void |
decodeRest(HornetQBuffer buffer) |
void |
encodeRest(HornetQBuffer buffer) |
boolean |
equals(Object obj) |
ReplicationStartSyncMessage.SyncDataType |
getDataType() |
long[] |
getFileIds() |
String |
getNodeID() |
int |
hashCode() |
boolean |
isServerToFailBack() |
boolean |
isSynchronizationFinished() |
decode, encode, getChannelID, getPacketSize, getParentString, getType, isRequiresConfirmations, isResponse, nullableStringEncodeSize, setChannelID, toString
public ReplicationStartSyncMessage()
public ReplicationStartSyncMessage(String nodeID)
public ReplicationStartSyncMessage(JournalFile[] datafiles, JournalStorageManager.JournalContent contentType, String nodeID, boolean allowsAutoFailBack)
public void encodeRest(HornetQBuffer buffer)
encodeRest
in class PacketImpl
public void decodeRest(HornetQBuffer buffer)
decodeRest
in class PacketImpl
public boolean isServerToFailBack()
Configuration#isAllowAutoFailBack()
public boolean isSynchronizationFinished()
true
if the live has finished synchronizing its data and the backup is
therefore up-to-date, false
otherwise.public ReplicationStartSyncMessage.SyncDataType getDataType()
public long[] getFileIds()
public String getNodeID()
public int hashCode()
hashCode
in class PacketImpl
public boolean equals(Object obj)
equals
in class PacketImpl
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.