Package io.micronaut.rabbitmq.connect.recovery

Class TemporarilyDownConnectionManager

java.lang.Object

io.micronaut.rabbitmq.connect.recovery.TemporarilyDownConnectionManager

@Singleton
public class TemporarilyDownConnectionManager
extends Object

Creates temporarily down RabbitMQ connections and checks periodically if they are eventually up.

Since:

4.1.0

Author:

Guillermo Calvo

Constructor Summary

Constructors

Constructor	Description
TemporarilyDownConnectionManager()

Method Summary

Modifier and Type	Method	Description
TemporarilyDownConnection	newConnection(RabbitConnectionFactoryConfig factory, ExecutorService executor)	Creates a new temporarily down RabbitMQ connection.

Methods inherited from class java.lang.Object

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

Constructor Details

TemporarilyDownConnectionManager

public TemporarilyDownConnectionManager()

Method Details

newConnection

public TemporarilyDownConnection newConnection(RabbitConnectionFactoryConfig factory,
 ExecutorService executor)

Creates a new temporarily down RabbitMQ connection.

Parameters:

factory - The factory to create the connection.

executor - The executor service.

Returns:

a new TemporarilyDownConnection