Interface GridNioFuture<R>
-
- All Superinterfaces:
IgniteInternalFuture<R>
- All Known Implementing Classes:
GridNioEmbeddedFuture,GridNioFinishedFuture,GridNioFutureImpl
public interface GridNioFuture<R> extends IgniteInternalFuture<R>
NIO future.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description IgniteInClosure<IgniteException>ackClosure()booleanmessageThread()voidmessageThread(boolean msgThread)Sets flag indicating that message send future was created in thread that was processing a message.voidonAckReceived()The method will be called when ack received.booleanskipRecovery()-
Methods inherited from interface org.apache.ignite.internal.IgniteInternalFuture
cancel, chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, listen, result
-
-
-
-
Method Detail
-
messageThread
void messageThread(boolean msgThread)
Sets flag indicating that message send future was created in thread that was processing a message.- Parameters:
msgThread-Trueif future was created in thread that is processing message.
-
messageThread
boolean messageThread()
- Returns:
Trueif future was created in thread that was processing message.
-
skipRecovery
boolean skipRecovery()
- Returns:
Trueif skip recovery for this operation.
-
onAckReceived
void onAckReceived()
The method will be called when ack received.
-
ackClosure
IgniteInClosure<IgniteException> ackClosure()
- Returns:
- Ack closure.
-
-