Class StreamMessageHeader


  • public class StreamMessageHeader
    extends java.lang.Object
    StreamMessageHeader is appended before sending actual data to describe what it's sending.
    • Field Detail

      • tableId

        public final TableId tableId
      • planId

        public java.util.UUID planId
      • sendByFollower

        public final boolean sendByFollower
      • sessionIndex

        public int sessionIndex
      • sequenceNumber

        public final int sequenceNumber
      • repairedAt

        public final long repairedAt
      • pendingRepair

        public final java.util.UUID pendingRepair
    • Constructor Detail

      • StreamMessageHeader

        public StreamMessageHeader​(TableId tableId,
                                   InetAddressAndPort sender,
                                   java.util.UUID planId,
                                   boolean sendByFollower,
                                   int sessionIndex,
                                   int sequenceNumber,
                                   long repairedAt,
                                   java.util.UUID pendingRepair)
    • Method Detail

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object o)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object
      • addSessionInfo

        public void addSessionInfo​(StreamSession session)