Package org.ovirt.vdsm.jsonrpc.client.internal

Class ClientPolicy

java.lang.Object

org.ovirt.vdsm.jsonrpc.client.internal.ClientPolicy

Direct Known Subclasses:

AwaitRetry, DefaultClientRetryPolicy, DefaultConnectionRetryPolicy, StompClientPolicy

public class ClientPolicy
extends java.lang.Object

Java bean which provide information how retry logic should work.

Field Summary

Fields

Modifier and Type	Field	Description
private java.util.List<java.lang.Class<? extends java.lang.Exception>>	exceptions
private java.lang.String	identifier
private int	incomingHeartbeat
private java.util.concurrent.atomic.AtomicBoolean	isIncomingHeartbeat
private java.util.concurrent.atomic.AtomicBoolean	isOutgoingHeartbeat
private int	outgoingHeartbeat
private int	retryNumber
private int	retryTimeOut
private java.util.concurrent.TimeUnit	timeUnit

Constructor Summary

Constructors

Constructor	Description
ClientPolicy(int retryTimeOut, int retryNumber, int incomingHeartbeat)
ClientPolicy(int retryTimeOut, int retryNumber, int incomingHeartbeat, int outgoingHeartbeat)
ClientPolicy(int retryTimeOut, int retryNumber, int incomingHeartbeat, int outgoingHeartbeat, java.lang.Class<? extends java.lang.Exception> retryableException)
ClientPolicy(int retryTimeOut, int retryNumber, int incomingHeartbeat, int outgoingHeartbeat, java.util.List<java.lang.Class<? extends java.lang.Exception>> retryableExceptions)	Create policy using provided values.
ClientPolicy(int retryTimeOut, int retryNumber, int incomingHeartbeat, java.lang.Class<? extends java.lang.Exception> retryableException)

Method Summary

Modifier and Type	Method	Description
ClientPolicy	clone()
java.util.List<java.lang.Class<? extends java.lang.Exception>>	getExceptions()
java.lang.String	getIdentifier()
int	getIncomingHeartbeat()
int	getOutgoingHeartbeat()
int	getRetryNumber()
int	getRetryTimeOut()
java.util.concurrent.TimeUnit	getTimeUnit()
boolean	isIncomingHeartbeat()
boolean	isOutgoingHeartbeat()
void	setIdentifier(java.lang.String identifier)
void	setIncomingHeartbeat(boolean isHeartbeat)
void	setIncomingHeartbeat(int incomingHeartbeat)
void	setOutgoingHeartbeat(boolean isHeartbeat)
void	setOutgoingHeartbeat(int outgoingHeartbeat)
void	setTimeUnit(java.util.concurrent.TimeUnit timeUnit)

Methods inherited from class java.lang.Object

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

Field Detail

retryTimeOut

private final int retryTimeOut

retryNumber

private final int retryNumber

exceptions

private final java.util.List<java.lang.Class<? extends java.lang.Exception>> exceptions

isIncomingHeartbeat

private final java.util.concurrent.atomic.AtomicBoolean isIncomingHeartbeat

isOutgoingHeartbeat

private final java.util.concurrent.atomic.AtomicBoolean isOutgoingHeartbeat

incomingHeartbeat

private volatile int incomingHeartbeat

outgoingHeartbeat

private volatile int outgoingHeartbeat

timeUnit

private java.util.concurrent.TimeUnit timeUnit

identifier

private java.lang.String identifier

Constructor Detail

ClientPolicy

public ClientPolicy(int retryTimeOut,
                    int retryNumber,
                    int incomingHeartbeat,
                    int outgoingHeartbeat,
                    java.util.List<java.lang.Class<? extends java.lang.Exception>> retryableExceptions)

Create policy using provided values.

Parameters:

retryTimeOut - - Integer value which is used as timeout between operation retry combined with TimeUnit which is set to milliseconds by default.

retryNumber - - Integer value which defines number of retry attempts.

incomingHeartbeat - - Integer value which defines incoming heart beat.

outgoingHeartbeat - - Integer value which defines outgoing heart beat.

retryableExceptions - - List of retryable exceptions.

ClientPolicy

public ClientPolicy(int retryTimeOut,
                    int retryNumber,
                    int incomingHeartbeat)

ClientPolicy

public ClientPolicy(int retryTimeOut,
                    int retryNumber,
                    int incomingHeartbeat,
                    int outgoingHeartbeat)

ClientPolicy

public ClientPolicy(int retryTimeOut,
                    int retryNumber,
                    int incomingHeartbeat,
                    java.lang.Class<? extends java.lang.Exception> retryableException)

ClientPolicy

public ClientPolicy(int retryTimeOut,
                    int retryNumber,
                    int incomingHeartbeat,
                    int outgoingHeartbeat,
                    java.lang.Class<? extends java.lang.Exception> retryableException)

Method Detail

getRetryTimeOut

public int getRetryTimeOut()

getRetryNumber

public int getRetryNumber()

getIncomingHeartbeat

public int getIncomingHeartbeat()

getOutgoingHeartbeat

public int getOutgoingHeartbeat()

setOutgoingHeartbeat

public final void setOutgoingHeartbeat(int outgoingHeartbeat)

setIncomingHeartbeat

public final void setIncomingHeartbeat(int incomingHeartbeat)

getExceptions

public java.util.List<java.lang.Class<? extends java.lang.Exception>> getExceptions()

getTimeUnit

public java.util.concurrent.TimeUnit getTimeUnit()

getIdentifier

public java.lang.String getIdentifier()

setIdentifier

public void setIdentifier(java.lang.String identifier)

setTimeUnit

public void setTimeUnit(java.util.concurrent.TimeUnit timeUnit)

isIncomingHeartbeat

public boolean isIncomingHeartbeat()

setIncomingHeartbeat

public void setIncomingHeartbeat(boolean isHeartbeat)

isOutgoingHeartbeat

public boolean isOutgoingHeartbeat()

setOutgoingHeartbeat

public void setOutgoingHeartbeat(boolean isHeartbeat)

clone

public ClientPolicy clone()

Overrides:

clone in class java.lang.Object