org.apache.pekko.stream.connectors.jakartams
ConnectionRetrySettings
Companion object ConnectionRetrySettings
final class ConnectionRetrySettings extends AnyRef
When a connection to a broker cannot be established and errors out, or is timing out being established or started, the connection can be retried. All JMS publishers, consumers, and browsers are configured with connection retry settings.
- Alphabetic
- By Inheritance
- ConnectionRetrySettings
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- val backoffFactor: Double
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- val connectTimeout: FiniteDuration
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- val initialRetry: FiniteDuration
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val maxBackoff: FiniteDuration
- val maxRetries: Int
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- ConnectionRetrySettings → AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- def waitTime(retryNumber: Int): FiniteDuration
The wait time before the next attempt may be made.
- def withBackoffFactor(factor: Double): ConnectionRetrySettings
Back-off factor for subsequent retries.
- def withConnectTimeout(timeout: Duration): ConnectionRetrySettings
Java API: Time allowed to establish and start a connection.
- def withConnectTimeout(timeout: FiniteDuration): ConnectionRetrySettings
Time allowed to establish and start a connection.
- def withInfiniteRetries(): ConnectionRetrySettings
Do not limit the number of retries.
- def withInitialRetry(timeout: Duration): ConnectionRetrySettings
Java API: Wait time before retrying the first time.
- def withInitialRetry(timeout: FiniteDuration): ConnectionRetrySettings
Wait time before retrying the first time.
- def withMaxBackoff(backoffTime: Duration): ConnectionRetrySettings
Java API: Maximum back-off time allowed, after which all retries will happen after this delay.
- def withMaxBackoff(backoffTime: FiniteDuration): ConnectionRetrySettings
Maximum back-off time allowed, after which all retries will happen after this delay.
- def withMaxRetries(value: Int): ConnectionRetrySettings
Maximum number of retries allowed.