public class SubscriptionInfo
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static int |
LATEST_SUPPORTED_VERSION |
Modifier | Constructor and Description |
---|---|
protected |
SubscriptionInfo(int version,
int latestSupportedVersion,
java.util.UUID processId,
java.util.Set<TaskId> prevTasks,
java.util.Set<TaskId> standbyTasks,
java.lang.String userEndPoint) |
|
SubscriptionInfo(int version,
java.util.UUID processId,
java.util.Set<TaskId> prevTasks,
java.util.Set<TaskId> standbyTasks,
java.lang.String userEndPoint) |
|
SubscriptionInfo(java.util.UUID processId,
java.util.Set<TaskId> prevTasks,
java.util.Set<TaskId> standbyTasks,
java.lang.String userEndPoint) |
Modifier and Type | Method and Description |
---|---|
static SubscriptionInfo |
decode(java.nio.ByteBuffer data) |
java.nio.ByteBuffer |
encode() |
protected void |
encodeClientUUID(java.nio.ByteBuffer buf) |
protected void |
encodeTasks(java.nio.ByteBuffer buf,
java.util.Collection<TaskId> taskIds) |
protected void |
encodeUserEndPoint(java.nio.ByteBuffer buf,
byte[] endPointBytes) |
boolean |
equals(java.lang.Object o) |
protected int |
getVersionThreeAndFourByteLength(byte[] endPointBytes) |
int |
hashCode() |
int |
latestSupportedVersion() |
protected byte[] |
prepareUserEndPoint() |
java.util.Set<TaskId> |
prevTasks() |
java.util.UUID |
processId() |
java.util.Set<TaskId> |
standbyTasks() |
java.lang.String |
toString() |
java.lang.String |
userEndPoint() |
int |
version() |
public static final int LATEST_SUPPORTED_VERSION
public SubscriptionInfo(java.util.UUID processId, java.util.Set<TaskId> prevTasks, java.util.Set<TaskId> standbyTasks, java.lang.String userEndPoint)
public SubscriptionInfo(int version, java.util.UUID processId, java.util.Set<TaskId> prevTasks, java.util.Set<TaskId> standbyTasks, java.lang.String userEndPoint)
public int version()
public int latestSupportedVersion()
public java.util.UUID processId()
public java.util.Set<TaskId> prevTasks()
public java.util.Set<TaskId> standbyTasks()
public java.lang.String userEndPoint()
public java.nio.ByteBuffer encode()
TaskAssignmentException
- if method fails to encode the dataprotected void encodeClientUUID(java.nio.ByteBuffer buf)
protected void encodeTasks(java.nio.ByteBuffer buf, java.util.Collection<TaskId> taskIds)
protected byte[] prepareUserEndPoint()
protected void encodeUserEndPoint(java.nio.ByteBuffer buf, byte[] endPointBytes)
protected int getVersionThreeAndFourByteLength(byte[] endPointBytes)
public static SubscriptionInfo decode(java.nio.ByteBuffer data)
TaskAssignmentException
- if method fails to decode the datapublic int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object o)
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object