Package fr.codinbox.connector.velocity

Class Connector

java.lang.Object

fr.codinbox.connector.velocity.Connector

public class Connector
extends Object

Static service locator for accessing connector services on the Velocity platform.

This class provides global access to all four connector services. Services are initialized by the Velocity ConnectorPlugin at startup and should not be set externally.

Usage example:

 RedisConnectorService redis = Connector.getRedisService();
 DatabaseConnectorService db = Connector.getDatabaseService();
 RabbitMQConnectorService rabbit = Connector.getRabbitMQService();
 KafkaConnectorService kafka = Connector.getKafkaService();
 

Constructor Summary

Constructors

Constructor	Description
Connector()

Method Summary

Modifier and Type	Method	Description
static @NotNull DatabaseConnectorService	getDatabaseService()	Returns the database connector service.
static @NotNull KafkaConnectorService	getKafkaService()	Returns the Kafka connector service.
static @NotNull RabbitMQConnectorService	getRabbitMQService()	Returns the RabbitMQ connector service.
static @NotNull RedisConnectorService	getRedisService()	Returns the Redis connector service.
protected static void	setDatabaseService(@NotNull DatabaseConnectorService service)
protected static void	setKafkaService(@NotNull KafkaConnectorService service)
protected static void	setRabbitMQService(@NotNull RabbitMQConnectorService service)
protected static void	setRedisService(@NotNull RedisConnectorService service)

Methods inherited from class java.lang.Object

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

Constructor Details

Connector

public Connector()

Method Details

getDatabaseService

@NotNull
public static @NotNull DatabaseConnectorService getDatabaseService()

Returns the database connector service.

Returns:

the initialized DatabaseConnectorService

Throws:

NullPointerException - if the service has not been initialized

getRedisService

@NotNull
public static @NotNull RedisConnectorService getRedisService()

Returns the Redis connector service.

Returns:

the initialized RedisConnectorService

Throws:

NullPointerException - if the service has not been initialized

getRabbitMQService

@NotNull
public static @NotNull RabbitMQConnectorService getRabbitMQService()

Returns the RabbitMQ connector service.

Returns:

the initialized RabbitMQConnectorService

Throws:

NullPointerException - if the service has not been initialized

getKafkaService

@NotNull
public static @NotNull KafkaConnectorService getKafkaService()

Returns the Kafka connector service.

Returns:

the initialized KafkaConnectorService

Throws:

NullPointerException - if the service has not been initialized

setDatabaseService

protected static void setDatabaseService(@NotNull
 @NotNull DatabaseConnectorService service)

setRedisService

protected static void setRedisService(@NotNull
 @NotNull RedisConnectorService service)

setRabbitMQService

protected static void setRabbitMQService(@NotNull
 @NotNull RabbitMQConnectorService service)

setKafkaService

protected static void setKafkaService(@NotNull
 @NotNull KafkaConnectorService service)