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

DBZ-2785 shut down Quarkus server if debezium-server crashes

Browse Source
This commit is contained in:
hauntingEcho 2020-11-30 13:57:46 -06:00 committed by Gunnar Morling
parent e5051647c1
commit f867e298cf
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
debezium-server/debezium-server-core/src/main/java/io/debezium/server/DebeziumServer.java
View File

@ -35,6 +35,7 @@
import io.debezium.engine.format.Avro; import io.debezium.engine.format.Avro;
import io.debezium.engine.format.Json; import io.debezium.engine.format.Json;
import io.debezium.engine.format.Protobuf; import io.debezium.engine.format.Protobuf;
import io.quarkus.runtime.Quarkus;
import io.quarkus.runtime.ShutdownEvent; import io.quarkus.runtime.ShutdownEvent;
import io.quarkus.runtime.Startup; import io.quarkus.runtime.Startup;
@ -136,7 +137,14 @@ else if (beans.size() > 1) {
.using((DebeziumEngine.CompletionCallback) health) .using((DebeziumEngine.CompletionCallback) health)
.build(); .build();
executor.execute(() -> engine.run()); executor.execute(() -> {
try {
engine.run();
}
finally {
Quarkus.asyncExit();
}
});
LOGGER.info("Engine executor started"); LOGGER.info("Engine executor started");
} }