Package io.debezium.pipeline.signal.channels.process

Class InProcessSignalChannel

java.lang.Object

io.debezium.pipeline.signal.channels.process.InProcessSignalChannel

All Implemented Interfaces:

SignalChannelWriter, SignalChannelReader

@ThreadSafe
public class InProcessSignalChannel
extends Object
implements SignalChannelReader, SignalChannelWriter

Implementation of SignalChannelReader that also implements SignalChannelWriter used for sending signal from the same JVM process

Mainly targeted at Debezium Engine

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CHANNEL_NAME
private static final org.slf4j.Logger	LOGGER
private final AtomicBoolean	open
private final Queue<SignalRecord>	signals

Constructor Summary

Constructors

Constructor	Description
InProcessSignalChannel()

Method Summary

Modifier and Type	Method	Description
void	close()	Close the channel and drain all the signals
private void	drain()
void	init(CommonConnectorConfig connectorConfig)
String	name()
List<SignalRecord>	read()
void	signal(SignalRecord signal)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.pipeline.signal.channels.SignalChannelReader

reset

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

CHANNEL_NAME

public static final String CHANNEL_NAME

See Also:

• Constant Field Values

open

private final AtomicBoolean open

signals

private final Queue<SignalRecord> signals

Constructor Details

InProcessSignalChannel

public InProcessSignalChannel()

Method Details

name

public String name()

Specified by:

name in interface SignalChannelReader

init

public void init(CommonConnectorConfig connectorConfig)

Specified by:

init in interface SignalChannelReader

read

public List<SignalRecord> read()

Specified by:

read in interface SignalChannelReader

close

public void close()

Close the channel and drain all the signals

Note: To properly synchronise closing and reading a lock should be used. However this is not necessary as any concurrent call to these methods is equal to serially calling read and close (or the other way around). The connector handles both cases (and the queue is already thread safe).

Specified by:

close in interface SignalChannelReader

drain

private void drain()

signal

public void signal(SignalRecord signal)

Specified by:

signal in interface SignalChannelWriter