org.apache.ignite.internal.util.nio

Class GridNioFinishedFuture<R>

java.lang.Object

org.apache.ignite.internal.util.future.GridFinishedFuture<R>

org.apache.ignite.internal.util.nio.GridNioFinishedFuture<R>

All Implemented Interfaces:

IgniteInternalFuture<R>, GridNioFuture<R>

public class GridNioFinishedFuture<R>
extends GridFinishedFuture<R>
implements GridNioFuture<R>

Future that represents already completed result.

Constructor Summary

Constructors

Constructor and Description
GridNioFinishedFuture(R res)
GridNioFinishedFuture(Throwable err)

Method Summary

Modifier and Type	Method and Description
IgniteInClosure<IgniteException>	ackClosure()
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()
String	toString()

Methods inherited from class org.apache.ignite.internal.util.future.GridFinishedFuture

cancel, chain, chain, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, 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, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, result

Constructor Detail

GridNioFinishedFuture

public GridNioFinishedFuture(R res)

Parameters:

res - Result.

GridNioFinishedFuture

public GridNioFinishedFuture(Throwable err)

Parameters:

err - Error.

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:

messageThread in interface GridNioFuture<R>

Parameters:

msgThread - True if future was created in thread that is processing message.

messageThread

public boolean messageThread()

Specified by:

messageThread in interface GridNioFuture<R>

Returns:

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

skipRecovery

public boolean skipRecovery()

Specified by:

skipRecovery in interface GridNioFuture<R>

Returns:

True if skip recovery for this operation.

onAckReceived

public void onAckReceived()

The method will be called when ack received.

Specified by:

onAckReceived in interface GridNioFuture<R>

ackClosure

public IgniteInClosure<IgniteException> ackClosure()

Specified by:

ackClosure in interface GridNioFuture<R>

Returns:

Ack closure.

toString

public String toString()

Overrides:

toString in class GridFinishedFuture<R>