public class OutboundTransferTask extends Object implements Runnable
Constructor and Description |
---|
OutboundTransferTask(Address destination,
Set<Integer> segments,
int stateTransferChunkSize,
int topologyId,
ConsistentHash readCh,
StateProviderImpl stateProvider,
DataContainer dataContainer,
CacheLoaderManager cacheLoaderManager,
RpcManager rpcManager,
CommandsFactory commandsFactory,
long timeout,
String cacheName) |
Modifier and Type | Method and Description |
---|---|
void |
cancel()
Cancel the whole task.
|
void |
cancelSegments(Set<Integer> cancelledSegments)
Cancel some of the segments.
|
void |
execute(ExecutorService executorService) |
Address |
getDestination() |
Set<Integer> |
getSegments() |
boolean |
isCancelled() |
void |
run() |
String |
toString() |
public OutboundTransferTask(Address destination, Set<Integer> segments, int stateTransferChunkSize, int topologyId, ConsistentHash readCh, StateProviderImpl stateProvider, DataContainer dataContainer, CacheLoaderManager cacheLoaderManager, RpcManager rpcManager, CommandsFactory commandsFactory, long timeout, String cacheName)
public void execute(ExecutorService executorService)
public Address getDestination()
public void cancelSegments(Set<Integer> cancelledSegments)
cancelledSegments
- segments to cancel.public void cancel()
public boolean isCancelled()
Copyright © 2017 JBoss, a division of Red Hat. All Rights Reserved.