Package io.debezium.processors

Class PostProcessorRegistry

java.lang.Object

io.debezium.processors.PostProcessorRegistry

All Implemented Interfaces:

Service, ServiceRegistryAware, Startable, Closeable, AutoCloseable

@ThreadSafe
public class PostProcessorRegistry
extends Object
implements Service, Startable, Closeable, ServiceRegistryAware

Registry of all post processors that are provided by the connector configuration.

Author:

Chris Cranford

Field Summary

Fields

Modifier and Type	Field	Description
private BeanRegistry	beanRegistry
private final List<PostProcessor>	processors
private ServiceRegistry	serviceRegistry

Constructor Summary

Constructors

Constructor	Description
PostProcessorRegistry(List<PostProcessor> processors)

Method Summary

Modifier and Type	Method	Description
void	close()
List<PostProcessor>	getProcessors()
void	injectServiceRegistry(ServiceRegistry serviceRegistry)	Callback to inject the service registry.
void	setBeanRegistry(BeanRegistry beanRegistry)
void	start()	Request the service to start.

Methods inherited from class java.lang.Object

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

Field Details

processors

@Immutable
private final List<PostProcessor> processors

beanRegistry

private BeanRegistry beanRegistry

serviceRegistry

private ServiceRegistry serviceRegistry

Constructor Details

PostProcessorRegistry

public PostProcessorRegistry(List<PostProcessor> processors)

Method Details

setBeanRegistry

public void setBeanRegistry(BeanRegistry beanRegistry)

injectServiceRegistry

public void injectServiceRegistry(ServiceRegistry serviceRegistry)

Description copied from interface: ServiceRegistryAware

Callback to inject the service registry.

Specified by:

injectServiceRegistry in interface ServiceRegistryAware

Parameters:

serviceRegistry - the service registry

start

public void start()

Description copied from interface: Startable

Request the service to start.

Specified by:

start in interface Startable

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

getProcessors

public List<PostProcessor> getProcessors()