Package io.streamthoughts.azkarra.api.components

Class BaseComponentModule

java.lang.Object

io.streamthoughts.azkarra.api.components.BaseComponentModule

All Implemented Interfaces:

ComponentFactoryAware, ConfigurableComponentFactory, Configurable

Direct Known Subclasses:

AutoCreateTopicsInterceptor, ComponentModule, ConditionalStreamsApplication.NormalizeStreamsTopology, MeterKafkaStreamsInterceptor, MeterRegistryFactory, MonitoringStreamsInterceptor

public abstract class BaseComponentModule
extends Object
implements ConfigurableComponentFactory, ComponentFactoryAware, Configurable

An abstract base class that can be extended to supply configurable components.

Constructor Summary

Constructors

Constructor	Description
BaseComponentModule()

Method Summary

Modifier and Type	Method	Description
void	configure(Conf configuration)	Configures this instance with the specified Conf.
ComponentFactory	getComponentFactory()	Gets the internal ComponentFactory.
Conf	getConfiguration()	Gets the configuration used by this component factory.
void	setComponentFactory(ComponentFactory factory)	Sets the ComponentFactory instance..

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.streamthoughts.azkarra.api.components.ConfigurableComponentFactory

getAllComponents, getAllComponents, getAllComponents, getAllComponents, getComponent, getComponent, getComponent, getComponent

Constructor Detail

BaseComponentModule

public BaseComponentModule()

Method Detail

setComponentFactory

public void setComponentFactory(ComponentFactory factory)

Sets the ComponentFactory instance..

Specified by:

setComponentFactory in interface ComponentFactoryAware

Parameters:

factory - the ComponentFactory instance.

configure

public void configure(Conf configuration)

Configures this instance with the specified Conf.

Specified by:

configure in interface Configurable

Parameters:

configuration - the Conf instance used to configure this instance.

getComponentFactory

public ComponentFactory getComponentFactory()

Gets the internal ComponentFactory.

Specified by:

getComponentFactory in interface ConfigurableComponentFactory

Returns:

the ComponentFactory instance to be used.

getConfiguration

public Conf getConfiguration()

Gets the configuration used by this component factory.

Specified by:

getConfiguration in interface ConfigurableComponentFactory

Returns:

the Conf