Package io.debezium.processors

Class PostProcessorRegistryServiceProvider

java.lang.Object

io.debezium.processors.PostProcessorRegistryServiceProvider

All Implemented Interfaces:

ServiceProvider<PostProcessorRegistry>

public class PostProcessorRegistryServiceProvider
extends Object
implements ServiceProvider<PostProcessorRegistry>

An implementation of the ServiceProvider contract for the PostProcessorRegistry.

Author:

Chris Cranford

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOGGER
private static final String	POST_PROCESSOR_MISS_CONFIGURATION_ERROR_MESSAGE
private final ServiceLoader<PostProcessorFactory>	postProcessorFactory
private final String	TYPE_SUFFIX

Constructor Summary

Constructors

Constructor	Description
PostProcessorRegistryServiceProvider()

Method Summary

Modifier and Type	Method	Description
PostProcessorRegistry	createService(io.debezium.config.Configuration configuration, ServiceRegistry serviceRegistry)	Creates or provides a desired service.
private PostProcessor	getPostProcessor(io.debezium.config.Configuration configuration, String postProcessorName)
private List<PostProcessor>	getPostProcessors(io.debezium.config.Configuration configuration, String postProcessorNameList)
Class<PostProcessorRegistry>	getServiceClass()	Get the service class that should be initiated or provided.

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

POST_PROCESSOR_MISS_CONFIGURATION_ERROR_MESSAGE

private static final String POST_PROCESSOR_MISS_CONFIGURATION_ERROR_MESSAGE

See Also:

• Constant Field Values

TYPE_SUFFIX

private final String TYPE_SUFFIX

See Also:

• Constant Field Values

postProcessorFactory

private final ServiceLoader<PostProcessorFactory> postProcessorFactory

Constructor Details

PostProcessorRegistryServiceProvider

public PostProcessorRegistryServiceProvider()

Method Details

createService

public PostProcessorRegistry createService(io.debezium.config.Configuration configuration,
 ServiceRegistry serviceRegistry)

Description copied from interface: ServiceProvider

Creates or provides a desired service.

Specified by:

createService in interface ServiceProvider<PostProcessorRegistry>

Parameters:

configuration - the connector configuration

serviceRegistry - the service registry

Returns:

the constructed service

getPostProcessors

private List<PostProcessor> getPostProcessors(io.debezium.config.Configuration configuration,
 String postProcessorNameList)

getPostProcessor

private PostProcessor getPostProcessor(io.debezium.config.Configuration configuration,
 String postProcessorName)

getServiceClass

public Class<PostProcessorRegistry> getServiceClass()

Description copied from interface: ServiceProvider

Get the service class that should be initiated or provided. The service class should be unique in the registry.

Specified by:

getServiceClass in interface ServiceProvider<PostProcessorRegistry>

Returns:

the service class