Index (Lyra 0.5.6-SNAPSHOT API)

A C D E F G H I L M N O R S T W
All Classes|All Packages

A

allowsAttempts() - Method in class net.jodah.lyra.config.RecoveryPolicy: Returns whether the policy allows any attempts based on the configured maxAttempts and maxDuration.
allowsAttempts() - Method in class net.jodah.lyra.config.RetryPolicy: Returns whether the policy allows any attempts based on the configured maxAttempts and maxDuration.

C

ChannelConfig - Interface in net.jodah.lyra.config: Channel related configuration.
ChannelListener - Interface in net.jodah.lyra.event: Listens for Channel related events.
Config - Class in net.jodah.lyra.config: Lyra configuration.
Config() - Constructor for class net.jodah.lyra.config.Config
Config(Config) - Constructor for class net.jodah.lyra.config.Config: Creates a new Config object that inherits configuration from the parent.
ConfigurableChannel - Interface in net.jodah.lyra.config: Configurable Channel.
ConfigurableConnection - Interface in net.jodah.lyra.config: Configurable Connection.
ConnectionConfig - Interface in net.jodah.lyra.config: Connection related configuration.
ConnectionListener - Interface in net.jodah.lyra.event: Listens for Connection related events.
ConnectionOptions - Class in net.jodah.lyra: Connection options.
ConnectionOptions() - Constructor for class net.jodah.lyra.ConnectionOptions
ConnectionOptions(ConnectionFactory) - Constructor for class net.jodah.lyra.ConnectionOptions: Creates a new Options object for the connectionFactory.
Connections - Class in net.jodah.lyra: Creates Lyra managed Connections through which Lyra managed Channels and Consumers can be created.
ConsumerConfig - Interface in net.jodah.lyra.config: Consumer related configuration.
ConsumerListener - Interface in net.jodah.lyra.event: Listens for Consumer related events.
copy() - Method in class net.jodah.lyra.ConnectionOptions: Returns a new copy of the options.
create(ConnectionFactory, Config) - Static method in class net.jodah.lyra.Connections: Creates and returns a new Lyra managed ConfigurableConnection for the given connectionFactory and config.
create(ConnectionFactory, Config, ClassLoader) - Static method in class net.jodah.lyra.Connections: Creates and returns a new Lyra managed ConfigurableConnection for the given connectionFactory and config.
create(Config) - Static method in class net.jodah.lyra.Connections: Creates and returns a new Lyra managed ConfigurableConnection for the given config.
create(Config, ClassLoader) - Static method in class net.jodah.lyra.Connections: Creates and returns a new Lyra managed ConfigurableConnection for the given config.
create(ConnectionOptions, Config) - Static method in class net.jodah.lyra.Connections: Creates and returns a new Lyra managed ConfigurableConnection for the given options and config.
create(ConnectionOptions, Config, ClassLoader) - Static method in class net.jodah.lyra.Connections: Creates and returns a new Lyra managed ConfigurableConnection for the given options and config.

D

days(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count days.
DefaultChannelListener - Class in net.jodah.lyra.event: No-op channel listener for sub-classing.
DefaultChannelListener() - Constructor for class net.jodah.lyra.event.DefaultChannelListener
DefaultConnectionListener - Class in net.jodah.lyra.event: No-op connection listener for sub-classing.
DefaultConnectionListener() - Constructor for class net.jodah.lyra.event.DefaultConnectionListener
DefaultConsumerListener - Class in net.jodah.lyra.event: No-op consumer listener for sub-classing.
DefaultConsumerListener() - Constructor for class net.jodah.lyra.event.DefaultConsumerListener
Duration - Class in net.jodah.lyra.util: Duration unit, consisting of length and time unit.

E

equals(Object) - Method in class net.jodah.lyra.util.Duration

F

finite - Variable in class net.jodah.lyra.util.Duration

G

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: Sets the policy to use for handling connection attempt errors.
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
getNioParams() - Method in class net.jodah.lyra.ConnectionOptions: Return NioParams object.
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.

H

hashCode() - Method in class net.jodah.lyra.util.Duration
hours(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count hours.

I

inf() - Static method in class net.jodah.lyra.util.Duration: Returns an infinite duration of Long.MAX_VALUE days.
infinite() - Static method in class net.jodah.lyra.util.Duration: Returns an infinite duration of Long.MAX_VALUE days.
INFINITE - Static variable in class net.jodah.lyra.util.Duration: A duration of Long.MAX_VALUE Days
isConsumerRecoveryEnabled() - Method in class net.jodah.lyra.config.Config
isConsumerRecoveryEnabled() - Method in interface net.jodah.lyra.config.ConsumerConfig: Returns whether consumer recovery is enabled.
isExchangeRecoveryEnabled() - Method in interface net.jodah.lyra.config.ChannelConfig: Returns whether exchange and exchange binding recovery is enabled.
isExchangeRecoveryEnabled() - Method in class net.jodah.lyra.config.Config
isQueueRecoveryEnabled() - Method in interface net.jodah.lyra.config.ChannelConfig: Returns whether queue and queue binding recovery is enabled.
isQueueRecoveryEnabled() - Method in class net.jodah.lyra.config.Config
isUsingDaemonThreads() - Method in class net.jodah.lyra.config.Config
isUsingDaemonThreads() - Method in interface net.jodah.lyra.config.ConnectionConfig: Whether or not using daemon threads.

L

length - Variable in class net.jodah.lyra.util.Duration

M

microseconds(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count microseconds.
millis(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count milliseconds.
milliseconds(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count milliseconds.
mins(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count minutes.
minutes(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count minutes.

N

nanos(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count nanoseconds.
nanoseconds(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count nanoseconds.
net.jodah.lyra - package net.jodah.lyra
net.jodah.lyra.config - package net.jodah.lyra.config
net.jodah.lyra.event - package net.jodah.lyra.event
net.jodah.lyra.util - package net.jodah.lyra.util

O

of(long, TimeUnit) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count units.
of(Channel) - Static method in class net.jodah.lyra.config.Config: Returns the channel as a ConfigurableChannel.
of(Connection) - Static method in class net.jodah.lyra.config.Config: Returns the connection as a ConfigurableConnection.
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(Channel) - Method in class net.jodah.lyra.event.DefaultChannelListener
onCreate(Connection) - Method in interface net.jodah.lyra.event.ConnectionListener: Called when the connection is successfully created.
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(Channel) - Method in class net.jodah.lyra.event.DefaultChannelListener
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(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(Channel) - Method in class net.jodah.lyra.event.DefaultChannelListener
onRecoveryCompleted(Connection) - Method in interface net.jodah.lyra.event.ConnectionListener: Called when recovery of the connection and its associated resources is completed.
onRecoveryCompleted(Connection) - Method in class net.jodah.lyra.event.DefaultConnectionListener
onRecoveryCompleted(Consumer, Channel) - Method in interface net.jodah.lyra.event.ConsumerListener: Called when recovery of the consumer on the channel is successfully completed.
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(Channel, Throwable) - Method in class net.jodah.lyra.event.DefaultChannelListener
onRecoveryFailure(Connection, Throwable) - Method in interface net.jodah.lyra.event.ConnectionListener: Called when the connection fails to recover from an unexpected closure.
onRecoveryFailure(Connection, Throwable) - Method in class net.jodah.lyra.event.DefaultConnectionListener
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(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(Channel) - Method in class net.jodah.lyra.event.DefaultChannelListener
onRecoveryStarted(Connection) - Method in interface net.jodah.lyra.event.ConnectionListener: Called when recovery of the connection is started.
onRecoveryStarted(Connection) - Method in class net.jodah.lyra.event.DefaultConnectionListener
onRecoveryStarted(Consumer, Channel) - Method in interface net.jodah.lyra.event.ConsumerListener: Called when recovery of the consumer on the channel is started.
onRecoveryStarted(Consumer, Channel) - Method in class net.jodah.lyra.event.DefaultConsumerListener

R

recoverAlways() - Static method in class net.jodah.lyra.config.RecoveryPolicies: Returns a RecoveryPolicy that always recovers.
recoverNever() - Static method in class net.jodah.lyra.config.RecoveryPolicies: Returns a RecoveryPolicy that never recovers.
RecoveryPolicies - Class in net.jodah.lyra.config: Factory methods for recovery policies.
RecoveryPolicy - Class in net.jodah.lyra.config: Policy that defines how recovery should be performed.
RecoveryPolicy() - Constructor for class net.jodah.lyra.config.RecoveryPolicy: Creates a recovery policy that always recovers.
retryAlways() - Static method in class net.jodah.lyra.config.RetryPolicies: Returns a RetryPolicy that always retries.
retryNever() - Static method in class net.jodah.lyra.config.RetryPolicies: Returns a RetryPolicy that never retries.
RetryPolicies - Class in net.jodah.lyra.config: Factory methods for retry policies.
RetryPolicy - Class in net.jodah.lyra.config: Policy that defines how retries should be performed.
RetryPolicy() - Constructor for class net.jodah.lyra.config.RetryPolicy: Creates a retry policy that retries forever.

S

seconds(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count seconds.
secs(long) - Static method in class net.jodah.lyra.util.Duration: Returns a Duration of count seconds.

T

timeUnit - Variable in class net.jodah.lyra.util.Duration
toDays() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to days.
toHours() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to hours.
toMicros() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to microseconds.
toMicroseconds() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to microseconds.
toMillis() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to milliseconds.
toMilliseconds() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to milliseconds.
toMins() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to minutes.
toMinutes() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to minutes.
toNanos() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to nanoseconds.
toNanoseconds() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to nanoseconds.
toSeconds() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to seconds.
toSecs() - Method in class net.jodah.lyra.util.Duration: Returns the Duration converted to seconds.
toString() - Method in class net.jodah.lyra.util.Duration

W

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) - 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.RecoveryPolicy: Sets the interval to pause for between attempts, exponentially backing of to the maxInterval multiplying successive intervals by the intervalMultiplier.
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: Sets the policy to use for handling initial connection attempt errors.
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.
withNio() - Method in class net.jodah.lyra.ConnectionOptions: Support for Java non-blocking IO
withNioParams(NioParams) - Method in class net.jodah.lyra.ConnectionOptions: Support for Java non-blocking IO
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(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.
withSslProtocol(SSLContext) - Method in class net.jodah.lyra.ConnectionOptions: Sets the initialized sslContext to use.
withUri(String) - Method in class net.jodah.lyra.ConnectionOptions: Convenience method for setting the fields in an AMQP URI: host, port, username, password and virtual host.
withUri(URI) - Method in class net.jodah.lyra.ConnectionOptions: Convenience method for setting the fields in an AMQP URI: host, port, username, password and virtual host.
withUseDaemonThreads(boolean) - Method in class net.jodah.lyra.config.Config
withUseDaemonThreads(boolean) - Method in interface net.jodah.lyra.config.ConnectionConfig: Whether or not using daemon threads.
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.

A C D E F G H I L M N O R S T W
All Classes|All Packages