DBZ-7110 Use better name for DebeziumEngine.Builder implementation
This commit is contained in:
parent
c34cf6920c
commit
cf7f0f3801
@ -79,7 +79,7 @@ public class ConvertingEngineBuilder<R> implements Builder<R> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
ConvertingEngineBuilder(KeyValueHeaderChangeEventFormat<?, ?, ?> format) {
|
ConvertingEngineBuilder(KeyValueHeaderChangeEventFormat<?, ?, ?> format) {
|
||||||
this.delegate = new EmbeddedEngine.BuilderImpl();
|
this.delegate = new EmbeddedEngine.EngineBuilder();
|
||||||
this.formatKey = format.getKeyFormat();
|
this.formatKey = format.getKeyFormat();
|
||||||
this.formatValue = format.getValueFormat();
|
this.formatValue = format.getValueFormat();
|
||||||
this.formatHeader = format.getHeaderFormat();
|
this.formatHeader = format.getHeaderFormat();
|
||||||
|
@ -84,7 +84,7 @@
|
|||||||
@ThreadSafe
|
@ThreadSafe
|
||||||
public final class EmbeddedEngine implements DebeziumEngine<SourceRecord>, EmbeddedEngineConfig {
|
public final class EmbeddedEngine implements DebeziumEngine<SourceRecord>, EmbeddedEngineConfig {
|
||||||
|
|
||||||
public static final class BuilderImpl implements Builder<SourceRecord> {
|
public static final class EngineBuilder implements Builder<SourceRecord> {
|
||||||
private Configuration config;
|
private Configuration config;
|
||||||
private DebeziumEngine.ChangeConsumer<SourceRecord> handler;
|
private DebeziumEngine.ChangeConsumer<SourceRecord> handler;
|
||||||
private ClassLoader classLoader;
|
private ClassLoader classLoader;
|
||||||
|
@ -404,7 +404,7 @@ public void connectorStopped() {
|
|||||||
};
|
};
|
||||||
|
|
||||||
// Create the connector ...
|
// Create the connector ...
|
||||||
EmbeddedEngine.Builder builder = new EmbeddedEngine.BuilderImpl();
|
EmbeddedEngine.Builder builder = new EmbeddedEngine.EngineBuilder();
|
||||||
builder.using(config.asProperties())
|
builder.using(config.asProperties())
|
||||||
.notifying(getConsumer(isStopRecord, recordArrivedListener, ignoreRecordsAfterStop))
|
.notifying(getConsumer(isStopRecord, recordArrivedListener, ignoreRecordsAfterStop))
|
||||||
.using(this.getClass().getClassLoader())
|
.using(this.getClass().getClassLoader())
|
||||||
|
@ -126,7 +126,7 @@ public void doSetup() {
|
|||||||
.build();
|
.build();
|
||||||
|
|
||||||
Consumer<SourceRecord> recordArrivedListener = this::processRecord;
|
Consumer<SourceRecord> recordArrivedListener = this::processRecord;
|
||||||
this.engine = (EmbeddedEngine) new EmbeddedEngine.BuilderImpl()
|
this.engine = (EmbeddedEngine) new EmbeddedEngine.EngineBuilder()
|
||||||
.using(config.asProperties())
|
.using(config.asProperties())
|
||||||
.notifying((record) -> {
|
.notifying((record) -> {
|
||||||
if (!engine.isRunning() || Thread.currentThread().isInterrupted()) {
|
if (!engine.isRunning() || Thread.currentThread().isInterrupted()) {
|
||||||
|
Loading…
Reference in New Issue
Block a user