Package io.debezium.connector.base

Class QueueProviderServiceProvider

java.lang.Object

io.debezium.connector.base.QueueProviderServiceProvider

All Implemented Interfaces:

ServiceProvider<QueueProviderService>

public class QueueProviderServiceProvider
extends Object
implements ServiceProvider<QueueProviderService>

An implementation of the ServiceProvider contract for the QueueProviderService.

Author:

Chris Cranford

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
QueueProviderServiceProvider()

Method Summary

Modifier and Type	Method	Description
QueueProviderService	createService(io.debezium.config.Configuration configuration, ServiceRegistry serviceRegistry)	Creates or provides a desired service.
Class<QueueProviderService>	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

Constructor Details

QueueProviderServiceProvider

public QueueProviderServiceProvider()

Method Details

createService

public QueueProviderService 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<QueueProviderService>

Parameters:

configuration - the connector configuration

serviceRegistry - the service registry

Returns:

the constructed service

getServiceClass

public Class<QueueProviderService> 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<QueueProviderService>

Returns:

the service class