This is an automated email from the ASF dual-hosted git repository. ppalaga pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git
commit 521a7493901168849cbde2833c81754b799c074f Author: Peter Palaga <[email protected]> AuthorDate: Mon Jan 11 22:28:54 2021 +0100 Make Debezium tests runnable on Quarkus Platform --- .../debezium/common/it/mongodb/DebeziumMongodbTestResource.java | 6 +++--- .../debezium/common/it/postgres/DebeziumPostgresTestResource.java | 2 +- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/mongodb/DebeziumMongodbTestResource.java b/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/mongodb/DebeziumMongodbTestResource.java index f604aa4..086141a 100644 --- a/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/mongodb/DebeziumMongodbTestResource.java +++ b/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/mongodb/DebeziumMongodbTestResource.java @@ -17,11 +17,11 @@ package org.apache.camel.quarkus.component.debezium.common.it.mongodb; -import java.nio.file.Files; -import java.nio.file.Paths; +import java.nio.charset.StandardCharsets; import org.apache.camel.quarkus.component.debezium.common.it.AbstractDebeziumTestResource; import org.apache.camel.quarkus.component.debezium.common.it.Type; +import org.apache.commons.io.IOUtils; import org.jboss.logging.Logger; import org.testcontainers.containers.Container; import org.testcontainers.containers.GenericContainer; @@ -62,7 +62,7 @@ public class DebeziumMongodbTestResource extends AbstractDebeziumTestResource<Ge } private void execScriptInContainer(String script) throws Exception { - String cmd = new String(Files.readAllBytes(Paths.get(getClass().getResource("/" + script).toURI()))); + String cmd = IOUtils.toString(getClass().getResource("/" + script), StandardCharsets.UTF_8); String[] cmds = cmd.split("\\n\\n"); for (int i = 0; i < cmds.length; i++) { diff --git a/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/postgres/DebeziumPostgresTestResource.java b/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/postgres/DebeziumPostgresTestResource.java index 28d23b4..e431cd9 100644 --- a/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/postgres/DebeziumPostgresTestResource.java +++ b/integration-tests/debezium/src/test/java/org/apache/camel/quarkus/component/debezium/common/it/postgres/DebeziumPostgresTestResource.java @@ -36,7 +36,7 @@ public class DebeziumPostgresTestResource extends AbstractDebeziumTestResource<P @Override protected PostgreSQLContainer createContainer() { - DockerImageName imageName = DockerImageName.parse(POSTGRES_IMAGE) + DockerImageName imageName = new DockerImageName(POSTGRES_IMAGE) .asCompatibleSubstituteFor("postgres"); return new PostgreSQLContainer<>(imageName) .withUsername(DB_USERNAME)
