Package | Description |
---|---|
net.jodah.lyra | |
net.jodah.lyra.config |
Modifier and Type | Method and Description |
---|---|
static ConfigurableConnection |
Connections.create(Config config)
Creates and returns a new Lyra managed ConfigurableConnection for the given
config . |
static ConfigurableConnection |
Connections.create(com.rabbitmq.client.ConnectionFactory connectionFactory,
Config config)
Creates and returns a new Lyra managed ConfigurableConnection for the given
connectionFactory and config . |
static ConfigurableConnection |
Connections.create(ConnectionOptions options,
Config config)
Creates and returns a new Lyra managed ConfigurableConnection for the given
options and
config . |
Modifier and Type | Method and Description |
---|---|
Config |
Config.withChannelListeners(ChannelListener... channelListeners) |
Config |
Config.withChannelRecoveryPolicy(RecoveryPolicy channelRecoveryPolicy) |
Config |
Config.withChannelRetryPolicy(RetryPolicy channelRetryPolicy) |
Config |
Config.withConnectionListeners(ConnectionListener... connectionListeners) |
Config |
Config.withConnectionRecoveryPolicy(RecoveryPolicy connectionRecoveryPolicy) |
Config |
Config.withConnectionRetryPolicy(RetryPolicy connectionRetryPolicy) |
Config |
Config.withConnectRetryPolicy(RetryPolicy connectRetryPolicy)
Sets the policy to use for handling initial
connection attempt errors. |
Config |
Config.withConsumerListeners(ConsumerListener... consumerListeners) |
Config |
Config.withConsumerRecovery(boolean enabled) |
Config |
Config.withExchangeRecovery(boolean enabled) |
Config |
Config.withQueueRecovery(boolean enabled) |
Config |
Config.withRecoveryPolicy(RecoveryPolicy recoveryPolicy)
Sets the policy to use for the recovery of Connections/Channels/Consumers after an unexpected
Connection/Channel closure.
|
Config |
Config.withRetryPolicy(RetryPolicy retryPolicy)
Sets the policy to use for handling
connection attempt , Connection invocation, and Channel invocation errors. |
Constructor and Description |
---|
Config(Config parent)
Creates a new Config object that inherits configuration from the
parent . |
Copyright © 2016. All rights reserved.