Package fr.codinbox.connector.commons.rabbitmq

Class RabbitMQConnectorServiceImpl

java.lang.Object

fr.codinbox.connector.commons.rabbitmq.RabbitMQConnectorServiceImpl

All Implemented Interfaces:

RabbitMQConnectorService

public class RabbitMQConnectorServiceImpl
extends Object
implements RabbitMQConnectorService

Default implementation of RabbitMQConnectorService that discovers and manages RabbitMQ connections from environment variables.

See Also:

• RabbitMQConnectorService
• RabbitMQConnectionImpl

Constructor Summary

Constructors

Constructor	Description
RabbitMQConnectorServiceImpl(@NotNull Logger logger)	Creates a new RabbitMQ connector service.

Method Summary

Modifier and Type	Method	Description
@NotNull Optional<RabbitMQConnection>	getConnection(@NotNull String id)	Retrieves a RabbitMQ connection by its identifier.
void	init()	Initializes all RabbitMQ connections discovered from environment variables.
void	shutdown()	Shuts down all managed RabbitMQ connections, closing channels and connections.

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitMQConnectorServiceImpl

public RabbitMQConnectorServiceImpl(@NotNull
 @NotNull Logger logger)

Creates a new RabbitMQ connector service.

Parameters:

logger - the logger for diagnostic messages

Method Details

init

public void init()
          throws ConnectionInitException

Description copied from interface: RabbitMQConnectorService

Initializes all RabbitMQ connections discovered from environment variables.

Specified by:

init in interface RabbitMQConnectorService

Throws:

ConnectionInitException - if a connection with exit-on-failure enabled fails to initialize

shutdown

public void shutdown()

Description copied from interface: RabbitMQConnectorService

Shuts down all managed RabbitMQ connections, closing channels and connections.

Specified by:

shutdown in interface RabbitMQConnectorService

getConnection

@NotNull
public @NotNull Optional<RabbitMQConnection> getConnection(@NotNull
 @NotNull String id)

Description copied from interface: RabbitMQConnectorService

Retrieves a RabbitMQ connection by its identifier.

Specified by:

getConnection in interface RabbitMQConnectorService

Parameters:

id - the connection identifier (case-sensitive, as extracted from environment variables)

Returns:

an Optional containing the connection, or empty if no connection exists with that id