- getAddresses() - Method in class net.jodah.lyra.ConnectionOptions
-
Returns the addresses to attempt connections to, in round-robin order.
- getChannelListeners() - Method in interface net.jodah.lyra.config.ChannelConfig
-
Returns the channel's listeners else empty list if none were configured.
- getChannelListeners() - Method in class net.jodah.lyra.config.Config
-
- getChannelRecoveryPolicy() - Method in interface net.jodah.lyra.config.ChannelConfig
-
Returns the channel's recovery policy.
- getChannelRecoveryPolicy() - Method in class net.jodah.lyra.config.Config
-
- getChannelRetryPolicy() - Method in interface net.jodah.lyra.config.ChannelConfig
-
Returns the channel's retry policy.
- getChannelRetryPolicy() - Method in class net.jodah.lyra.config.Config
-
- getConnectionFactory() - Method in class net.jodah.lyra.ConnectionOptions
-
Returns the ConnectionFactory for the options.
- getConnectionListeners() - Method in class net.jodah.lyra.config.Config
-
- getConnectionListeners() - Method in interface net.jodah.lyra.config.ConnectionConfig
-
Returns the connection's listeners else empty list if none were configured.
- getConnectionRecoveryPolicy() - Method in class net.jodah.lyra.config.Config
-
- getConnectionRecoveryPolicy() - Method in interface net.jodah.lyra.config.ConnectionConfig
-
Returns the connection's recovery policy.
- getConnectionRetryPolicy() - Method in class net.jodah.lyra.config.Config
-
- getConnectionRetryPolicy() - Method in interface net.jodah.lyra.config.ConnectionConfig
-
Returns the connection's retry policy.
- getConnectRetryPolicy() - Method in class net.jodah.lyra.config.Config
-
- getConsumerExecutor() - Method in class net.jodah.lyra.ConnectionOptions
-
Returns the consumer executor.
- getConsumerListeners() - Method in class net.jodah.lyra.config.Config
-
- getConsumerListeners() - Method in interface net.jodah.lyra.config.ConsumerConfig
-
Returns the consumer listeners else empty list if none were configured.
- getInterval() - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Returns the interval between attempts.
- getInterval() - Method in class net.jodah.lyra.config.RetryPolicy
-
Returns the interval between attempts.
- getIntervalMultiplier() - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Returns the interval multiplier for backoff attempts.
- getIntervalMultiplier() - Method in class net.jodah.lyra.config.RetryPolicy
-
Returns the interval multiplier for backoff attempts.
- getMaxAttempts() - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Returns the max attempts.
- getMaxAttempts() - Method in class net.jodah.lyra.config.RetryPolicy
-
Returns the max attempts.
- getMaxDuration() - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Returns the max duration to perform attempts for.
- getMaxDuration() - Method in class net.jodah.lyra.config.RetryPolicy
-
Returns the max duration to perform attempts for.
- getMaxInterval() - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Returns the max interval between backoff attempts.
- getMaxInterval() - Method in class net.jodah.lyra.config.RetryPolicy
-
Returns the max interval between backoff attempts.
- getName() - Method in class net.jodah.lyra.ConnectionOptions
-
- getRecoverableExceptions() - Method in class net.jodah.lyra.config.Config
-
Returns the exceptions which will be recovered from.
- getRetryableExceptions() - Method in class net.jodah.lyra.config.Config
-
Returns the exceptions for which invocations will be retried.
- of(Channel) - Static method in class net.jodah.lyra.config.Config
-
- of(Connection) - Static method in class net.jodah.lyra.config.Config
-
- of(long, TimeUnit) - Static method in class net.jodah.lyra.util.Duration
-
Returns a Duration of count
unit
s.
- of(String) - Static method in class net.jodah.lyra.util.Duration
-
Returns a Duration from the parsed duration
.
- onCreate(Channel) - Method in interface net.jodah.lyra.event.ChannelListener
-
Called when the channel
is successfully created.
- onCreate(Connection) - Method in interface net.jodah.lyra.event.ConnectionListener
-
Called when the connection
is successfully created.
- onCreate(Channel) - Method in class net.jodah.lyra.event.DefaultChannelListener
-
- onCreate(Connection) - Method in class net.jodah.lyra.event.DefaultConnectionListener
-
- onCreateFailure(Throwable) - Method in interface net.jodah.lyra.event.ChannelListener
-
Called when channel creation fails.
- onCreateFailure(Throwable) - Method in interface net.jodah.lyra.event.ConnectionListener
-
Called when connection creation fails.
- onCreateFailure(Throwable) - Method in class net.jodah.lyra.event.DefaultChannelListener
-
- onCreateFailure(Throwable) - Method in class net.jodah.lyra.event.DefaultConnectionListener
-
- onRecovery(Channel) - Method in interface net.jodah.lyra.event.ChannelListener
-
Called when the channel
is successfully recovered from an unexpected closure but before
its consumers and their associated queues, exchanges, and bindings are recovered.
- onRecovery(Connection) - Method in interface net.jodah.lyra.event.ConnectionListener
-
Called when the connection
is successfully recovered from an unexpected closure, but
before its associated exchanges, queues, bindings, channels and consumers are recovered.
- onRecovery(Channel) - Method in class net.jodah.lyra.event.DefaultChannelListener
-
- onRecovery(Connection) - Method in class net.jodah.lyra.event.DefaultConnectionListener
-
- onRecoveryCompleted(Channel) - Method in interface net.jodah.lyra.event.ChannelListener
-
Called when recovery of the channel
and its consumers is completed.
- onRecoveryCompleted(Connection) - Method in interface net.jodah.lyra.event.ConnectionListener
-
Called when recovery of the connection
and its associated resources is completed.
- onRecoveryCompleted(Consumer, Channel) - Method in interface net.jodah.lyra.event.ConsumerListener
-
Called when recovery of the consumer
on the channel
is successfully completed.
- onRecoveryCompleted(Channel) - Method in class net.jodah.lyra.event.DefaultChannelListener
-
- onRecoveryCompleted(Connection) - Method in class net.jodah.lyra.event.DefaultConnectionListener
-
- onRecoveryCompleted(Consumer, Channel) - Method in class net.jodah.lyra.event.DefaultConsumerListener
-
- onRecoveryFailure(Channel, Throwable) - Method in interface net.jodah.lyra.event.ChannelListener
-
Called when the channel
fails to recover from an unexpected closure.
- onRecoveryFailure(Connection, Throwable) - Method in interface net.jodah.lyra.event.ConnectionListener
-
Called when the connection
fails to recover from an unexpected closure.
- onRecoveryFailure(Consumer, Channel, Throwable) - Method in interface net.jodah.lyra.event.ConsumerListener
-
Called when the consumer
fails to recover from an unexpected closure on the
channel
.
- onRecoveryFailure(Channel, Throwable) - Method in class net.jodah.lyra.event.DefaultChannelListener
-
- onRecoveryFailure(Connection, Throwable) - Method in class net.jodah.lyra.event.DefaultConnectionListener
-
- onRecoveryFailure(Consumer, Channel, Throwable) - Method in class net.jodah.lyra.event.DefaultConsumerListener
-
- onRecoveryStarted(Channel) - Method in interface net.jodah.lyra.event.ChannelListener
-
Called when recovery of the channel
is started.
- onRecoveryStarted(Connection) - Method in interface net.jodah.lyra.event.ConnectionListener
-
Called when recovery of the connection
is started.
- onRecoveryStarted(Consumer, Channel) - Method in interface net.jodah.lyra.event.ConsumerListener
-
Called when recovery of the consumer
on the channel
is started.
- onRecoveryStarted(Channel) - Method in class net.jodah.lyra.event.DefaultChannelListener
-
- onRecoveryStarted(Connection) - Method in class net.jodah.lyra.event.DefaultConnectionListener
-
- onRecoveryStarted(Consumer, Channel) - Method in class net.jodah.lyra.event.DefaultConsumerListener
-
- withAddresses(Address...) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the addresses
to attempt connections to, in round-robin order.
- withAddresses(String) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the addresses
.
- withBackoff(Duration, Duration) - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Sets the interval
to pause for between attempts, exponentially backing of to the
maxInterval
multiplying successive intervals by a factor of 2.
- withBackoff(Duration, Duration, int) - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Sets the interval
to pause for between attempts, exponentially backing of to the
maxInterval
multiplying successive intervals by the intervalMultiplier
.
- withBackoff(Duration, Duration) - Method in class net.jodah.lyra.config.RetryPolicy
-
Sets the interval
to pause for between attempts, exponentially backing of to the
maxInterval
multiplying successive intervals by a factor of 2.
- withBackoff(Duration, Duration, int) - Method in class net.jodah.lyra.config.RetryPolicy
-
Sets the interval
to pause for between attempts, exponentially backing of to the
maxInterval
multiplying successive intervals by the intervalMultiplier
.
- withChannelListeners(ChannelListener...) - Method in interface net.jodah.lyra.config.ChannelConfig
-
Sets the channelListeners
to call on channel related events.
- withChannelListeners(ChannelListener...) - Method in class net.jodah.lyra.config.Config
-
- withChannelRecoveryPolicy(RecoveryPolicy) - Method in interface net.jodah.lyra.config.ChannelConfig
-
Sets the recoveryPolicy
to use for recovering the channel.
- withChannelRecoveryPolicy(RecoveryPolicy) - Method in class net.jodah.lyra.config.Config
-
- withChannelRetryPolicy(RetryPolicy) - Method in interface net.jodah.lyra.config.ChannelConfig
-
Sets the retryPolicy
to use for retrying failed invocations on the channel.
- withChannelRetryPolicy(RetryPolicy) - Method in class net.jodah.lyra.config.Config
-
- withClientProperties(Map<String, Object>) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the client properties.
- withConnectionFactory(ConnectionFactory) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the connectionFactory
.
- withConnectionListeners(ConnectionListener...) - Method in class net.jodah.lyra.config.Config
-
- withConnectionListeners(ConnectionListener...) - Method in interface net.jodah.lyra.config.ConnectionConfig
-
Sets the connectionListeners
to call on connection related events.
- withConnectionRecoveryPolicy(RecoveryPolicy) - Method in class net.jodah.lyra.config.Config
-
- withConnectionRecoveryPolicy(RecoveryPolicy) - Method in interface net.jodah.lyra.config.ConnectionConfig
-
Sets the policy to use for the recovery of Connections after an unexpected Connection closure.
- withConnectionRetryPolicy(RetryPolicy) - Method in class net.jodah.lyra.config.Config
-
- withConnectionRetryPolicy(RetryPolicy) - Method in interface net.jodah.lyra.config.ConnectionConfig
-
Sets the policy to use for handling Connection
invocation errors.
- withConnectionTimeout(Duration) - Method in class net.jodah.lyra.ConnectionOptions
-
Set the connection timeout, zero for infinite, for an individual connection attempt.
- withConnectRetryPolicy(RetryPolicy) - Method in class net.jodah.lyra.config.Config
-
- withConsumerExecutor(ExecutorService) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the executor used to handle consumer callbacks.
- withConsumerListeners(ConsumerListener...) - Method in class net.jodah.lyra.config.Config
-
- withConsumerListeners(ConsumerListener...) - Method in interface net.jodah.lyra.config.ConsumerConfig
-
Sets the consumerListeners
to call on consumer related events.
- withConsumerRecovery(boolean) - Method in class net.jodah.lyra.config.Config
-
- withConsumerRecovery(boolean) - Method in interface net.jodah.lyra.config.ConsumerConfig
-
Sets whether consumer recovery is enabled or not.
- withExchangeRecovery(boolean) - Method in interface net.jodah.lyra.config.ChannelConfig
-
Sets whether exchange and exchange binding recovery is enabled or not.
- withExchangeRecovery(boolean) - Method in class net.jodah.lyra.config.Config
-
- withHost(String) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the host
.
- withHosts(String...) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the hosts
to attempt connections to, in round-robin order.
- withInterval(Duration) - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Sets the interval
to pause for between attempts.
- withInterval(Duration) - Method in class net.jodah.lyra.config.RetryPolicy
-
Sets the interval
to pause for between attempts.
- withMaxAttempts(int) - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Sets the max number of attempts to perform.
- withMaxAttempts(int) - Method in class net.jodah.lyra.config.RetryPolicy
-
Sets the max number of attempts to perform.
- withMaxDuration(Duration) - Method in class net.jodah.lyra.config.RecoveryPolicy
-
Sets the max duration to perform attempts for.
- withMaxDuration(Duration) - Method in class net.jodah.lyra.config.RetryPolicy
-
Sets the max duration to perform attempts for.
- withName(String) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the connection name.
- withPassword(String) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the password.
- withPort(int) - Method in class net.jodah.lyra.ConnectionOptions
-
Set the port.
- withQueueRecovery(boolean) - Method in interface net.jodah.lyra.config.ChannelConfig
-
Sets whether queue and queue binding recovery is enabled or not.
- withQueueRecovery(boolean) - Method in class net.jodah.lyra.config.Config
-
- withRecoveryPolicy(RecoveryPolicy) - Method in class net.jodah.lyra.config.Config
-
Sets the policy to use for the recovery of Connections/Channels/Consumers after an unexpected
Connection/Channel closure.
- withRequestedHeartbeat(Duration) - Method in class net.jodah.lyra.ConnectionOptions
-
Set the requested heartbeat, zero for none.
- withRetryPolicy(RetryPolicy) - Method in class net.jodah.lyra.config.Config
-
Sets the policy to use for handling
connection attempt
,
Connection
invocation, and
Channel
invocation errors.
- withSocketFactory(SocketFactory) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the SocketFactory to create connections with.
- withSsl() - Method in class net.jodah.lyra.ConnectionOptions
-
Enabled SSL using SSLv3.
- withSslProtocol(SSLContext) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the initialized sslContext
to use.
- withSslProtocol(String) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the sslProtocol
to use.
- withSslProtocol(String, TrustManager) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the sslProtocol
and trustManager
to use.
- withUsername(String) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the username.
- withVirtualHost(String) - Method in class net.jodah.lyra.ConnectionOptions
-
Sets the virtual host.