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 received.
boolean	messageThread()
void	messageThread(boolean msgThread) Sets flag indicating that message send future was created in thread that was processing a message.
void	onAckReceived() The method will be called when ack received.
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 received.

Parameters:

closure - Ack closure.

onAckReceived

void onAckReceived()

The method will be called when ack received.

ackClosure

IgniteInClosure<IgniteException> ackClosure()

Returns:

Ack closure.