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

Class ReplicationStartSyncMessage

java.lang.Object
org.apache.activemq.artemis.core.protocol.core.impl.PacketImpl
org.apache.activemq.artemis.core.protocol.core.impl.wireformat.ReplicationStartSyncMessage
All Implemented Interfaces:
Packet
public class ReplicationStartSyncMessage extends PacketImpl
This message may signal start or end of the replication synchronization.

At start, it sends all fileIDs used in a given journal primary server to the backup, so the backup can reserve those IDs.

  • Constructor Details

    • ReplicationStartSyncMessage

      public ReplicationStartSyncMessage()

    • ReplicationStartSyncMessage

      public ReplicationStartSyncMessage(List<Long> filenames)

    • ReplicationStartSyncMessage

      public ReplicationStartSyncMessage(String nodeID, long nodeDataVersion)

    • ReplicationStartSyncMessage

      public ReplicationStartSyncMessage(JournalFile[] datafiles, AbstractJournalStorageManager.JournalContent contentType, String nodeID, boolean allowsAutoFailBack)

  • Method Details

    • expectedEncodeSize

      public int expectedEncodeSize()
      Description copied from interface: Packet
      This will return the expected packet size for the encoding

    • encodeRest

      public void encodeRest(ActiveMQBuffer buffer)
      Overrides:
      encodeRest in class PacketImpl

    • decodeRest

      public void decodeRest(ActiveMQBuffer buffer)
      Overrides:
      decodeRest in class PacketImpl

    • isServerToFailBack

      public boolean isServerToFailBack()
      Returns:
      whether the server is configured to allow for fail-back

    • isSynchronizationFinished

      public boolean isSynchronizationFinished()
      Returns:
      true if the primary has finished synchronizing its data and the backup is therefore up-to-date, false otherwise.

    • getDataType

      public ReplicationStartSyncMessage.SyncDataType getDataType()

    • getFileIds

      public long[] getFileIds()

    • getNodeID

      public String getNodeID()

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class PacketImpl

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class PacketImpl

    • getPacketString

      protected String getPacketString()
      Overrides:
      getPacketString in class PacketImpl