Class SubscriptionInfo


  • public class SubscriptionInfo
    extends java.lang.Object
    • Field Detail

      • LATEST_SUPPORTED_VERSION

        public static final int LATEST_SUPPORTED_VERSION
        See Also:
        Constant Field Values
    • Constructor Detail

      • SubscriptionInfo

        public SubscriptionInfo​(java.util.UUID processId,
                                java.util.Set<TaskId> prevTasks,
                                java.util.Set<TaskId> standbyTasks,
                                java.lang.String userEndPoint)
      • SubscriptionInfo

        public SubscriptionInfo​(int version,
                                java.util.UUID processId,
                                java.util.Set<TaskId> prevTasks,
                                java.util.Set<TaskId> standbyTasks,
                                java.lang.String userEndPoint)
      • SubscriptionInfo

        protected SubscriptionInfo​(int version,
                                   int latestSupportedVersion,
                                   java.util.UUID processId,
                                   java.util.Set<TaskId> prevTasks,
                                   java.util.Set<TaskId> standbyTasks,
                                   java.lang.String userEndPoint)
    • Method Detail

      • version

        public int version()
      • latestSupportedVersion

        public int latestSupportedVersion()
      • processId

        public java.util.UUID processId()
      • prevTasks

        public java.util.Set<TaskId> prevTasks()
      • standbyTasks

        public java.util.Set<TaskId> standbyTasks()
      • userEndPoint

        public java.lang.String userEndPoint()
      • encode

        public java.nio.ByteBuffer encode()
        Throws:
        TaskAssignmentException - if method fails to encode the data
      • encodeClientUUID

        protected void encodeClientUUID​(java.nio.ByteBuffer buf)
      • encodeTasks

        protected void encodeTasks​(java.nio.ByteBuffer buf,
                                   java.util.Collection<TaskId> taskIds)
      • prepareUserEndPoint

        protected byte[] prepareUserEndPoint()
      • encodeUserEndPoint

        protected void encodeUserEndPoint​(java.nio.ByteBuffer buf,
                                          byte[] endPointBytes)
      • getVersionThreeAndFourByteLength

        protected int getVersionThreeAndFourByteLength​(byte[] endPointBytes)
      • hashCode

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

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

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