org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Class StopCachesOnClientReconnectExchangeTask

java.lang.Object

org.apache.ignite.internal.util.future.GridFutureAdapter<Void>

org.apache.ignite.internal.processors.cache.distributed.dht.preloader.StopCachesOnClientReconnectExchangeTask

All Implemented Interfaces:

IgniteInternalFuture<Void>, CachePartitionExchangeWorkerTask

public class StopCachesOnClientReconnectExchangeTask
extends GridFutureAdapter<Void>
implements CachePartitionExchangeWorkerTask

Constructor Summary

Constructors

Constructor and Description
StopCachesOnClientReconnectExchangeTask(Collection<GridCacheAdapter> stoppedCaches)

Method Summary

Modifier and Type	Method and Description
boolean	skipForExchangeMerge()
Collection<GridCacheAdapter>	stoppedCaches()
String	toString()

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

cancel, chain, chain, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, onCancelled, onDone, onDone, onDone, onDone, onDone, reset, result

Methods inherited from class java.lang.Object

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

Constructor Detail

StopCachesOnClientReconnectExchangeTask

public StopCachesOnClientReconnectExchangeTask(Collection<GridCacheAdapter> stoppedCaches)

Parameters:

stoppedCaches - Collection of stopped caches.

Method Detail

skipForExchangeMerge

public boolean skipForExchangeMerge()

Specified by:

skipForExchangeMerge in interface CachePartitionExchangeWorkerTask

Returns:

False if exchange merge should stop if this task is found in exchange worker queue.

stoppedCaches

public Collection<GridCacheAdapter> stoppedCaches()

Returns:

Collection of stopped caches.

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<Void>