org.apache.ignite.internal.util.nio

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

Methods

Modifier and Type	Method and Description
IgniteInClosure<IgniteException>	ackClosure()
void	ackClosure(IgniteInClosure<IgniteException> closure) Sets ack closure which will be applied when ack recevied.
boolean	messageThread()
void	messageThread(boolean msgThread) Sets flag indicating that message send future was created in thread that was processing a message.
boolean	skipRecovery()

Methods inherited from interface org.apache.ignite.internal.IgniteInternalFuture

cancel, chain, duration, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, result, startTime

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 - True if future was created in thread that is processing message.

messageThread

boolean messageThread()

Returns:

True if future was created in thread that was processing message.

skipRecovery

boolean skipRecovery()

Returns:

True if skip recovery for this operation.

ackClosure

void ackClosure(IgniteInClosure<IgniteException> closure)

Sets ack closure which will be applied when ack recevied.

Parameters:

closure - Ack closure.

ackClosure

IgniteInClosure<IgniteException> ackClosure()

Returns:

Ack closure.