public abstract class WaitKey extends Object implements DataSerializable
Modifier and Type | Field and Description |
---|---|
protected Address |
callerAddress |
protected long |
callId |
protected long |
commitIndex |
protected UUID |
invocationUid |
Constructor and Description |
---|
WaitKey() |
WaitKey(long commitIndex,
UUID invocationUid,
Address callerAddress,
long callId) |
Modifier and Type | Method and Description |
---|---|
Address |
callerAddress()
Returns address of the caller which created this wait key
|
long |
callId()
Returns the call id which created this wait key
|
long |
commitIndex()
Returns commit index of the operation that has not returned a response
at the time of its commit.
|
UUID |
invocationUid()
Returns unique id of the committed operation which is provided by the caller.
|
void |
readData(ObjectDataInput in)
Reads fields from the input stream
|
abstract long |
sessionId()
Returns id of the session to which the corresponding operation is
attached.
|
void |
writeData(ObjectDataOutput out)
Writes object fields to output stream
|
protected long commitIndex
protected UUID invocationUid
protected Address callerAddress
protected long callId
public abstract long sessionId()
AbstractProxySessionManager.NO_SESSION_ID
if no session
is attached.public final long commitIndex()
public final UUID invocationUid()
public final Address callerAddress()
public final long callId()
public void writeData(ObjectDataOutput out) throws IOException
DataSerializable
writeData
in interface DataSerializable
out
- outputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
output stream has been closed.public void readData(ObjectDataInput in) throws IOException
DataSerializable
readData
in interface DataSerializable
in
- inputIOException
- if an I/O error occurs. In particular,
an IOException
may be thrown if the
input stream has been closed.Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.