org.infinispan.remoting.transport

Class RetryOnFailureXSiteCommand

java.lang.Object

org.infinispan.remoting.transport.RetryOnFailureXSiteCommand

public class RetryOnFailureXSiteCommand
extends Object

Invokes a command in a remote site. This class allows to set a RetryOnFailureXSiteCommand.RetryPolicy to retry the command in case of an exception. The RetryOnFailureXSiteCommand.RetryPolicy has the exception to decide if it should retry or not.

Since:

7.0

Author:

Pedro Ruivo

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RetryOnFailureXSiteCommand.MaxRetriesPolicy
static interface	RetryOnFailureXSiteCommand.RetryPolicy

Field Summary

Fields

Modifier and Type	Field and Description
static RetryOnFailureXSiteCommand.RetryPolicy	NO_RETRY

Method Summary

Modifier and Type	Method and Description
void	execute(RpcManager rpcManager, long waitTimeBetweenRetries, TimeUnit unit) Invokes remotely the command using the Transport passed as parameter.
static RetryOnFailureXSiteCommand	newInstance(XSiteBackup backup, XSiteReplicateCommand command, RetryOnFailureXSiteCommand.RetryPolicy retryPolicy) It builds a new instance with the destination site, the command and the retry policy.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

NO_RETRY

public static final RetryOnFailureXSiteCommand.RetryPolicy NO_RETRY

Method Detail

execute

public void execute(RpcManager rpcManager,
                    long waitTimeBetweenRetries,
                    TimeUnit unit)
             throws Throwable

Invokes remotely the command using the Transport passed as parameter.

Parameters:

rpcManager - the RpcManager to use.

waitTimeBetweenRetries - the waiting time if the command fails before retrying it.

unit - the TimeUnit of the waiting time.

Throws:

Throwable - if the maximum retries is reached (defined by the RetryOnFailureXSiteCommand.RetryPolicy, the last exception occurred is thrown.

newInstance

public static RetryOnFailureXSiteCommand newInstance(XSiteBackup backup,
                                                     XSiteReplicateCommand command,
                                                     RetryOnFailureXSiteCommand.RetryPolicy retryPolicy)

It builds a new instance with the destination site, the command and the retry policy.

Parameters:

backup - the destination site.

command - the command to invoke remotely.

retryPolicy - the retry policy.

Returns:

the new instance.

Throws:

NullPointerException - if any parameter is null

toString

public String toString()

Overrides:

toString in class Object