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
All Methods Instance Methods Concrete Methods 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)
-
-
-
Field Detail
-
retryTimeOut
private final int retryTimeOut
-
retryNumber
private final int retryNumber
-
incomingHeartbeat
private volatile int incomingHeartbeat
-
outgoingHeartbeat
private volatile int outgoingHeartbeat
-
exceptions
private java.util.List<java.lang.Class<? extends java.lang.Exception>> exceptions
-
timeUnit
private java.util.concurrent.TimeUnit timeUnit
-
isIncomingHeartbeat
private java.util.concurrent.atomic.AtomicBoolean isIncomingHeartbeat
-
isOutgoingHeartbeat
private java.util.concurrent.atomic.AtomicBoolean isOutgoingHeartbeat
-
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 withTimeUnit
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 classjava.lang.Object
-
-