Package fr.codinbox.connector.commons.redis

Class RedisConnectorServiceImpl

java.lang.Object

fr.codinbox.connector.commons.redis.RedisConnectorServiceImpl

All Implemented Interfaces:

RedisConnectorService

public class RedisConnectorServiceImpl
extends Object
implements RedisConnectorService

Default implementation of RedisConnectorService that discovers and manages Redis connections from environment variables.

See Also:

• RedisConnectorService
• RedisConnectionImpl

Constructor Summary

Constructors

Constructor	Description
RedisConnectorServiceImpl(@NotNull Logger logger)	Creates a new Redis connector service.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

RedisConnectorServiceImpl

public RedisConnectorServiceImpl(@NotNull
 @NotNull Logger logger)

Creates a new Redis connector service.

Parameters:

logger - the logger for diagnostic messages

Method Details

init

public void init()
          throws ConnectionInitException

Description copied from interface: RedisConnectorService

Initializes all Redis connections discovered from environment variables.

Specified by:

init in interface RedisConnectorService

Throws:

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

shutdown

public void shutdown()

Description copied from interface: RedisConnectorService

Shuts down all managed Redis connections.

Specified by:

shutdown in interface RedisConnectorService

getConnection

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

Description copied from interface: RedisConnectorService

Retrieves a Redis connection by its identifier.

Specified by:

getConnection in interface RedisConnectorService

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