Uses of Interface
io.debezium.connector.base.QueueProvider

Packages that use QueueProvider

Package	Description
io.debezium.connector.base

Uses of QueueProvider in io.debezium.connector.base

Classes in io.debezium.connector.base that implement QueueProvider

Modifier and Type	Class	Description
class	DefaultQueueProvider<T extends Sizeable>	Default implementation of QueueProvider using an ArrayDeque.

Fields in io.debezium.connector.base declared as QueueProvider

Modifier and Type	Field	Description
private final QueueProvider<T>	ChangeEventQueue.queue
private QueueProvider<T>	ChangeEventQueue.Builder.queueProvider
private final QueueProvider<?>	QueueProviderService.queueProvider

Methods in io.debezium.connector.base that return QueueProvider

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

Methods in io.debezium.connector.base with parameters of type QueueProvider

Modifier and Type	Method	Description
ChangeEventQueue.Builder<T>	ChangeEventQueue.Builder.queueProvider(QueueProvider<T> queueProvider)	Sets a custom QueueProvider implementation to be used by the ChangeEventQueue.

Constructors in io.debezium.connector.base with parameters of type QueueProvider

Modifier	Constructor	Description
private	ChangeEventQueue(Duration pollInterval, int maxQueueSize, int maxBatchSize, Supplier<LoggingContext.PreviousContext> loggingContextSupplier, long maxQueueSizeInBytes, boolean buffering, QueueProvider<T> queueProvider)
	QueueProviderService(QueueProvider<?> queueProvider)