Class ClientPolicy

    • 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 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()
                           throws java.lang.CloneNotSupportedException
        Overrides:
        clone in class java.lang.Object
        Throws:
        java.lang.CloneNotSupportedException