Package io.debezium.connector.base

Class DefaultQueueProvider<T extends Sizeable>

java.lang.Object

io.debezium.connector.base.DefaultQueueProvider<T>

Type Parameters:

T - the type of elements in the queue, must implement Sizeable

All Implemented Interfaces:

QueueProvider<T>, io.debezium.spi.common.Configurable, AutoCloseable

public class DefaultQueueProvider<T extends Sizeable>
extends Object
implements QueueProvider<T>

Default implementation of QueueProvider using an ArrayDeque.

Field Summary

Fields

Modifier and Type	Field	Description
private Queue<T>	queue

Constructor Summary

Constructors

Constructor	Description
DefaultQueueProvider()

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> properties)
void	enqueue(T record)	Adds an event to the queue.
String	name()
T	poll()	Retrieves and removes the next event from the queue.
int	size()	Returns the number of events currently in the queue.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.connector.base.QueueProvider

close

Field Details

queue

private Queue<T extends Sizeable> queue

Constructor Details

DefaultQueueProvider

public DefaultQueueProvider()

Method Details

name

public String name()

Specified by:

name in interface QueueProvider<T extends Sizeable>

Returns:

the name of the queue provider

configure

public void configure(Map<String,?> properties)

Specified by:

configure in interface io.debezium.spi.common.Configurable

enqueue

public void enqueue(T record)
             throws InterruptedException

Description copied from interface: QueueProvider

Adds an event to the queue.

Specified by:

enqueue in interface QueueProvider<T extends Sizeable>

Parameters:

record - the event to enqueue

Throws:

InterruptedException - if interrupted while waiting to enqueue

poll

public T poll()
       throws InterruptedException

Description copied from interface: QueueProvider

Retrieves and removes the next event from the queue.

Specified by:

poll in interface QueueProvider<T extends Sizeable>

Returns:

the next event, or null if the queue is empty

Throws:

InterruptedException - if interrupted while waiting to poll

size

public int size()

Description copied from interface: QueueProvider

Returns the number of events currently in the queue.

Specified by:

size in interface QueueProvider<T extends Sizeable>

Returns:

the queue size