org.apache.ignite.internal.processors.cache

Class GridDeferredAckMessageSender

java.lang.Object

org.apache.ignite.internal.processors.cache.GridDeferredAckMessageSender

public abstract class GridDeferredAckMessageSender
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
GridClosureProcessor	closure Closure processor.

Constructor Summary

Constructors

Constructor and Description
GridDeferredAckMessageSender(GridTimeoutProcessor time, GridClosureProcessor closure)

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	finish(UUID nodeId, ConcurrentLinkedDeque8<GridCacheVersion> vers)
abstract int	getBufferSize()
abstract int	getTimeout()
void	sendDeferredAckMessage(UUID nodeId, GridCacheVersion ver)
void	stop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

closure

public GridClosureProcessor closure

Closure processor.

Constructor Detail

GridDeferredAckMessageSender

public GridDeferredAckMessageSender(GridTimeoutProcessor time,
                            GridClosureProcessor closure)

Parameters:

time - Time.

closure - Closure.

Method Detail

getTimeout

public abstract int getTimeout()

getBufferSize

public abstract int getBufferSize()

finish

public abstract void finish(UUID nodeId,
          ConcurrentLinkedDeque8<GridCacheVersion> vers)

stop

public void stop()

sendDeferredAckMessage

public void sendDeferredAckMessage(UUID nodeId,
                          GridCacheVersion ver)

Parameters:

nodeId - Node ID to send message to.

ver - Version to ack.