alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-8160 Renamed AsyncEngineSignaler to EmbeddedEngineSignaler as it no longer depends on Async engine

Browse Source
This commit is contained in:
Jakub Cechacek 2024-08-28 14:37:42 +02:00 committed by Jiri Pechanec
parent bec109308d
commit 0791ea7243
2 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
debezium-embedded/src/main/java/io/debezium/embedded/async/AsyncEngineSignaler.java → debezium-embedded/src/main/java/io/debezium/embedded/EmbeddedEngineSignaler.java
View File

@ -3,7 +3,7 @@
* *
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/ */
package io.debezium.embedded.async; package io.debezium.embedded;
import java.util.List; import java.util.List;
@ -11,10 +11,10 @@
import io.debezium.pipeline.signal.SignalRecord; import io.debezium.pipeline.signal.SignalRecord;
import io.debezium.pipeline.signal.channels.process.SignalChannelWriter; import io.debezium.pipeline.signal.channels.process.SignalChannelWriter;
public class AsyncEngineSignaler implements DebeziumEngine.Signaler { public class EmbeddedEngineSignaler implements DebeziumEngine.Signaler {
private final List<SignalChannelWriter> channels; private final List<SignalChannelWriter> channels;
public AsyncEngineSignaler(List<SignalChannelWriter> channels) { public EmbeddedEngineSignaler(List<SignalChannelWriter> channels) {
this.channels = channels; this.channels = channels;
} }

3
debezium-embedded/src/main/java/io/debezium/embedded/async/AsyncEmbeddedEngine.java
View File

@ -63,6 +63,7 @@
import io.debezium.embedded.DebeziumEngineCommon; import io.debezium.embedded.DebeziumEngineCommon;
import io.debezium.embedded.EmbeddedEngineChangeEvent; import io.debezium.embedded.EmbeddedEngineChangeEvent;
import io.debezium.embedded.EmbeddedEngineConfig; import io.debezium.embedded.EmbeddedEngineConfig;
import io.debezium.embedded.EmbeddedEngineSignaler;
import io.debezium.embedded.EmbeddedWorkerConfig; import io.debezium.embedded.EmbeddedWorkerConfig;
import io.debezium.embedded.KafkaConnectUtil; import io.debezium.embedded.KafkaConnectUtil;
import io.debezium.embedded.Transformations; import io.debezium.embedded.Transformations;
@ -840,7 +841,7 @@ public Signaler getSignaler() {
.map(SignalChannelWriter.class::cast) .map(SignalChannelWriter.class::cast)
.toList(); .toList();
signaler = new AsyncEngineSignaler(channels); signaler = new EmbeddedEngineSignaler(channels);
} }
return signaler; return signaler;
} }