Package fr.codinbox.connector.commons.rabbitmq

Class RabbitMQConnectionImpl

java.lang.Object

fr.codinbox.connector.commons.rabbitmq.RabbitMQConnectionImpl

All Implemented Interfaces:

RabbitMQConnection

public class RabbitMQConnectionImpl
extends Object
implements RabbitMQConnection

Implementation of RabbitMQConnection that manages a RabbitMQ connection and a fixed-size channel pool.

The channel pool is pre-populated at initialization time. Channels are borrowed and returned via PooledChannel, which implements AutoCloseable.

See Also:

• RabbitMQConnection
• PooledChannel

Constructor Summary

Constructors

Constructor	Description
RabbitMQConnectionImpl(@NotNull Logger logger, @NotNull String id, @NotNull String configFilePath)	Creates a new RabbitMQ connection instance.

Method Summary

Modifier and Type	Method	Description
@NotNull PooledChannel	borrowChannel()	Borrows a channel from the fixed-size pool.
Connection	getConnection()	Returns the underlying RabbitMQ connection.
void	init()	Initializes the RabbitMQ connection and pre-creates the channel pool.
boolean	isExitOnFailure()	Returns whether this connection is configured to cause server shutdown on initialization failure.
void	shutdown()	Shuts down the connection, closing all pooled channels and the underlying connection.

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitMQConnectionImpl

public RabbitMQConnectionImpl(@NotNull
 @NotNull Logger logger,
 @NotNull
 @NotNull String id,
 @NotNull
 @NotNull String configFilePath)

Creates a new RabbitMQ connection instance.

Parameters:

logger - the logger for diagnostic messages

id - the connection identifier

configFilePath - the path to the .properties configuration file

Method Details

init

public void init()
          throws ConnectionInitException

Description copied from interface: RabbitMQConnection

Initializes the RabbitMQ connection and pre-creates the channel pool.

Specified by:

init in interface RabbitMQConnection

Throws:

ConnectionInitException - if the connection or channel pool creation fails

shutdown

public void shutdown()

Description copied from interface: RabbitMQConnection

Shuts down the connection, closing all pooled channels and the underlying connection.

Specified by:

shutdown in interface RabbitMQConnection

getConnection

@NotNull
public Connection getConnection()

Description copied from interface: RabbitMQConnection

Returns the underlying RabbitMQ connection.

Specified by:

getConnection in interface RabbitMQConnection

Returns:

the raw Connection instance

borrowChannel

@NotNull
public @NotNull PooledChannel borrowChannel()
                                     throws InterruptedException

Description copied from interface: RabbitMQConnection

Borrows a channel from the fixed-size pool.

The returned PooledChannel implements AutoCloseable and should be used in a try-with-resources block to ensure the channel is returned to the pool.

Specified by:

borrowChannel in interface RabbitMQConnection

Returns:

a pooled channel wrapper

Throws:

InterruptedException - if the current thread is interrupted while waiting for a channel

isExitOnFailure

public boolean isExitOnFailure()

Description copied from interface: RabbitMQConnection

Returns whether this connection is configured to cause server shutdown on initialization failure.

Specified by:

isExitOnFailure in interface RabbitMQConnection

Returns:

true if the server should exit when this connection fails to initialize