Package io.debezium.connector.base

Class QueueProviderService

java.lang.Object

io.debezium.connector.base.QueueProviderService

All Implemented Interfaces:

Service

@ThreadSafe
public class QueueProviderService
extends Object
implements Service

Service that provides the resolved QueueProvider instance for buffering change events.

Author:

Chris Cranford

Field Summary

Fields

Modifier and Type	Field	Description
private final QueueProvider<?>	queueProvider

Constructor Summary

Constructors

Constructor	Description
QueueProviderService(QueueProvider<?> queueProvider)

Method Summary

Modifier and Type	Method	Description
<T> QueueProvider<T>	getQueueProvider()

Methods inherited from class java.lang.Object

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

Field Details

queueProvider

@Immutable
private final QueueProvider<?> queueProvider

Constructor Details

QueueProviderService

public QueueProviderService(QueueProvider<?> queueProvider)

Method Details

getQueueProvider

public <T> QueueProvider<T> getQueueProvider()