private static class DefaultExecutorService.RandomNodeTaskFailoverPolicy extends java.lang.Object implements DistributedTaskFailoverPolicy
Constructor and Description |
---|
DefaultExecutorService.RandomNodeTaskFailoverPolicy() |
Modifier and Type | Method and Description |
---|---|
org.infinispan.remoting.transport.Address |
failover(FailoverContext fc)
As parts of distributively executed task can fail due to the task itself throwing an exception
or it can be an Infinispan system caused failure (e.g node failed or left cluster during task
execution etc).
|
int |
maxFailoverAttempts()
Maximum number of fail over attempts permitted by this DistributedTaskFailoverPolicy
|
protected org.infinispan.remoting.transport.Address |
randomNode(java.util.List<org.infinispan.remoting.transport.Address> candidates,
org.infinispan.remoting.transport.Address failedExecutionLocation) |
public DefaultExecutorService.RandomNodeTaskFailoverPolicy()
public org.infinispan.remoting.transport.Address failover(FailoverContext fc)
DistributedTaskFailoverPolicy
failover
in interface DistributedTaskFailoverPolicy
protected org.infinispan.remoting.transport.Address randomNode(java.util.List<org.infinispan.remoting.transport.Address> candidates, org.infinispan.remoting.transport.Address failedExecutionLocation)
public int maxFailoverAttempts()
DistributedTaskFailoverPolicy
maxFailoverAttempts
in interface DistributedTaskFailoverPolicy