Class GridNioFutureImpl<R>
- java.lang.Object
-
- org.apache.ignite.internal.util.future.GridFutureAdapter<R>
-
- org.apache.ignite.internal.util.nio.GridNioFutureImpl<R>
-
- All Implemented Interfaces:
IgniteInternalFuture<R>,GridNioFuture<R>
- Direct Known Subclasses:
GridNioEmbeddedFuture
public class GridNioFutureImpl<R> extends GridFutureAdapter<R> implements GridNioFuture<R>
Default future implementation.
-
-
Field Summary
Fields Modifier and Type Field Description protected IgniteInClosure<IgniteException>ackC
-
Constructor Summary
Constructors Constructor Description GridNioFutureImpl(IgniteInClosure<IgniteException> ackC)
-
Method Summary
All Methods Instance Methods Concrete 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()StringtoString()-
Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter
cancel, chain, chain, chain, chain, chainCompose, chainCompose, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, listen, logger, onCancelled, onDone, onDone, onDone, onDone, onDone, reset, result
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
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
-
-
-
-
Field Detail
-
ackC
protected final IgniteInClosure<IgniteException> ackC
-
-
Constructor Detail
-
GridNioFutureImpl
public GridNioFutureImpl(IgniteInClosure<IgniteException> ackC)
- Parameters:
ackC- Ack closure.
-
-
Method Detail
-
messageThread
public void messageThread(boolean msgThread)
Sets flag indicating that message send future was created in thread that was processing a message.- Specified by:
messageThreadin interfaceGridNioFuture<R>- Parameters:
msgThread-Trueif future was created in thread that is processing message.
-
messageThread
public boolean messageThread()
- Specified by:
messageThreadin interfaceGridNioFuture<R>- Returns:
Trueif future was created in thread that was processing message.
-
skipRecovery
public boolean skipRecovery()
- Specified by:
skipRecoveryin interfaceGridNioFuture<R>- Returns:
Trueif skip recovery for this operation.
-
onAckReceived
public void onAckReceived()
The method will be called when ack received.- Specified by:
onAckReceivedin interfaceGridNioFuture<R>
-
ackClosure
public IgniteInClosure<IgniteException> ackClosure()
- Specified by:
ackClosurein interfaceGridNioFuture<R>- Returns:
- Ack closure.
-
toString
public String toString()
- Overrides:
toStringin classGridFutureAdapter<R>
-
-