Package org.nuxeo.runtime.kafka

Class KafkaChecker

java.lang.Object

org.nuxeo.runtime.kafka.KafkaChecker

All Implemented Interfaces:

BackingChecker

public class KafkaChecker
extends Object
implements BackingChecker

Since:

11.3

Constructor Summary

Constructors

Constructor	Description
KafkaChecker()

Method Summary

Modifier and Type	Method	Description
boolean	accepts(ConfigurationGenerator cg)	Test if the check has to be done for the given configuration.
void	check(ConfigurationGenerator cg)	Test the availbilty of the backing service.
protected KafkaConfigDescriptor	getConfig(ConfigurationGenerator cg)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaChecker

public KafkaChecker()

Method Detail

accepts

public boolean accepts(ConfigurationGenerator cg)

Description copied from interface: BackingChecker

Test if the check has to be done for the given configuration.

Specified by:

accepts in interface BackingChecker

Parameters:

cg - The current configuration

Returns:

true if BackingChecker.check(ConfigurationGenerator) has to be called.

check

public void check(ConfigurationGenerator cg)
           throws ConfigurationException

Description copied from interface: BackingChecker

Test the availbilty of the backing service.

Specified by:

check in interface BackingChecker

Parameters:

cg - The current configuration

Throws:

ConfigurationException - if backing service is not available.

getConfig

protected KafkaConfigDescriptor getConfig(ConfigurationGenerator cg)
                                   throws ConfigurationException

Throws:

ConfigurationException