Package org.apache.ignite.internal.processors.cache

Class GridDeferredAckMessageSender<T>

java.lang.Object

org.apache.ignite.internal.processors.cache.GridDeferredAckMessageSender<T>

public abstract class GridDeferredAckMessageSender<T>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
GridClosureProcessor	c	Closure processor.

Constructor Summary

Constructors

Constructor	Description
GridDeferredAckMessageSender(GridTimeoutProcessor time, GridClosureProcessor c)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

c

public GridClosureProcessor c

Closure processor.

Constructor Detail

GridDeferredAckMessageSender

public GridDeferredAckMessageSender(GridTimeoutProcessor time,
                                    GridClosureProcessor c)

Parameters:

time - Time.

c - Closure.

Method Detail

getTimeout

public abstract int getTimeout()

Returns:

Timeout.

getBufferSize

public abstract int getBufferSize()

Returns:

Buffer size.

finish

public abstract void finish(UUID nodeId,
                            Collection<T> vers)

Parameters:

nodeId - Node ID.

vers - Versions to send.

stop

public void stop()

sendDeferredAckMessage

public void sendDeferredAckMessage(UUID nodeId,
                                   T ver)

Parameters:

nodeId - Node ID to send message to.

ver - Version to ack.