Package | Description |
---|---|
net.jodah.lyra.config |
Modifier and Type | Method and Description |
---|---|
RecoveryPolicy |
Config.getChannelRecoveryPolicy() |
RecoveryPolicy |
ChannelConfig.getChannelRecoveryPolicy()
Returns the channel's recovery policy.
|
RecoveryPolicy |
ConnectionConfig.getConnectionRecoveryPolicy()
Returns the connection's recovery policy.
|
RecoveryPolicy |
Config.getConnectionRecoveryPolicy() |
static RecoveryPolicy |
RecoveryPolicies.recoverAlways()
Returns a RecoveryPolicy that always recovers.
|
static RecoveryPolicy |
RecoveryPolicies.recoverNever()
Returns a RecoveryPolicy that never recovers.
|
RecoveryPolicy |
RecoveryPolicy.withBackoff(Duration interval,
Duration maxInterval)
Sets the
interval to pause for between attempts, exponentially backing of to the
maxInterval multiplying successive intervals by a factor of 2. |
RecoveryPolicy |
RecoveryPolicy.withBackoff(Duration interval,
Duration maxInterval,
int intervalMultiplier)
Sets the
interval to pause for between attempts, exponentially backing of to the
maxInterval multiplying successive intervals by the intervalMultiplier . |
RecoveryPolicy |
RecoveryPolicy.withInterval(Duration interval)
Sets the
interval to pause for between attempts. |
RecoveryPolicy |
RecoveryPolicy.withMaxAttempts(int maxAttempts)
Sets the max number of attempts to perform.
|
RecoveryPolicy |
RecoveryPolicy.withMaxDuration(Duration maxDuration)
Sets the max duration to perform attempts for.
|
Modifier and Type | Method and Description |
---|---|
Config |
Config.withChannelRecoveryPolicy(RecoveryPolicy channelRecoveryPolicy) |
ChannelConfig |
ChannelConfig.withChannelRecoveryPolicy(RecoveryPolicy recoveryPolicy)
Sets the
recoveryPolicy to use for recovering the channel. |
ConnectionConfig |
ConnectionConfig.withConnectionRecoveryPolicy(RecoveryPolicy recoveryPolicy)
Sets the policy to use for the recovery of Connections after an unexpected Connection closure.
|
Config |
Config.withConnectionRecoveryPolicy(RecoveryPolicy connectionRecoveryPolicy) |
Config |
Config.withRecoveryPolicy(RecoveryPolicy recoveryPolicy)
Sets the policy to use for the recovery of Connections/Channels/Consumers after an unexpected
Connection/Channel closure.
|
Copyright © 2016. All rights reserved.