Package net.jodah.lyra

Class Connections

java.lang.Object

net.jodah.lyra.Connections

public final class Connections
extends java.lang.Object

Creates Lyra managed Connections through which Lyra managed Channels and Consumers can be created.

Method Summary

Modifier and Type	Method	Description
static ConfigurableConnection	create(com.rabbitmq.client.ConnectionFactory connectionFactory, Config config)	Creates and returns a new Lyra managed ConfigurableConnection for the given connectionFactory and config.
static ConfigurableConnection	create(com.rabbitmq.client.ConnectionFactory connectionFactory, Config config, java.lang.ClassLoader classLoader)	Creates and returns a new Lyra managed ConfigurableConnection for the given connectionFactory and config.
static ConfigurableConnection	create(Config config)	Creates and returns a new Lyra managed ConfigurableConnection for the given config.
static ConfigurableConnection	create(Config config, java.lang.ClassLoader classLoader)	Creates and returns a new Lyra managed ConfigurableConnection for the given config.
static ConfigurableConnection	create(ConnectionOptions options, Config config)	Creates and returns a new Lyra managed ConfigurableConnection for the given options and config.
static ConfigurableConnection	create(ConnectionOptions options, Config config, java.lang.ClassLoader classLoader)	Creates and returns a new Lyra managed ConfigurableConnection for the given options and config.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

create

public static ConfigurableConnection create(Config config) throws java.io.IOException, java.util.concurrent.TimeoutException

Creates and returns a new Lyra managed ConfigurableConnection for the given config. If the connection attempt fails, retries will be performed according to the configured RetryPolicy before throwing the failure.

Throws:

java.lang.NullPointerException - if connectionFactory or config are null

java.io.IOException - if the connection could not be created

java.util.concurrent.TimeoutException

create

public static ConfigurableConnection create(Config config, java.lang.ClassLoader classLoader) throws java.io.IOException, java.util.concurrent.TimeoutException

Creates and returns a new Lyra managed ConfigurableConnection for the given config. If the connection attempt fails, retries will be performed according to the configured RetryPolicy before throwing the failure.

Throws:

java.lang.NullPointerException - if connectionFactory or config are null

java.io.IOException - if the connection could not be created

java.util.concurrent.TimeoutException

create

public static ConfigurableConnection create(com.rabbitmq.client.ConnectionFactory connectionFactory, Config config) throws java.io.IOException, java.util.concurrent.TimeoutException

Creates and returns a new Lyra managed ConfigurableConnection for the given connectionFactory and config. If the connection attempt fails, retries will be performed according to the configured RetryPolicy before throwing the failure.

Throws:

java.lang.NullPointerException - if connectionFactory or config are null

java.io.IOException - if the connection could not be created

java.util.concurrent.TimeoutException

create

public static ConfigurableConnection create(com.rabbitmq.client.ConnectionFactory connectionFactory, Config config, java.lang.ClassLoader classLoader) throws java.io.IOException, java.util.concurrent.TimeoutException

Creates and returns a new Lyra managed ConfigurableConnection for the given connectionFactory and config. If the connection attempt fails, retries will be performed according to the configured RetryPolicy before throwing the failure.

Throws:

java.lang.NullPointerException - if connectionFactory or config are null

java.io.IOException - if the connection could not be created

java.util.concurrent.TimeoutException

create

public static ConfigurableConnection create(ConnectionOptions options, Config config) throws java.io.IOException, java.util.concurrent.TimeoutException

Creates and returns a new Lyra managed ConfigurableConnection for the given options and config. If the connection attempt fails, retries will be performed according to the configured RetryPolicy before throwing the failure.

Throws:

java.lang.NullPointerException - if options or config are null

java.io.IOException - if the connection could not be created

java.util.concurrent.TimeoutException

create

public static ConfigurableConnection create(ConnectionOptions options, Config config, java.lang.ClassLoader classLoader) throws java.io.IOException, java.util.concurrent.TimeoutException

Creates and returns a new Lyra managed ConfigurableConnection for the given options and config. If the connection attempt fails, retries will be performed according to the configured RetryPolicy before throwing the failure.

Throws:

java.lang.NullPointerException - if options or config are null

java.io.IOException - if the connection could not be created

java.util.concurrent.TimeoutException