[camel-quarkus] branch main updated: pg-replication-slot: fix warning

[al...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

aldettinger pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-quarkus.git


The following commit(s) were added to refs/heads/main by this push:
     new aa9b919ed6 pg-replication-slot: fix warning
aa9b919ed6 is described below

commit aa9b919ed6076a5deb431559e5e92f16f5b8369e
Author: aldettinger <al...@gmail.com>
AuthorDate: Fri Sep 2 18:44:53 2022 +0200

    pg-replication-slot: fix warning
---
 .../pg/replication/slot/it/PgReplicationSlotTestResource.java         | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/integration-tests/pg-replication-slot/src/test/java/org/apache/camel/quarkus/component/pg/replication/slot/it/PgReplicationSlotTestResource.java b/integration-tests/pg-replication-slot/src/test/java/org/apache/camel/quarkus/component/pg/replication/slot/it/PgReplicationSlotTestResource.java
index c7b696cba0..74b830b895 100644
--- a/integration-tests/pg-replication-slot/src/test/java/org/apache/camel/quarkus/component/pg/replication/slot/it/PgReplicationSlotTestResource.java
+++ b/integration-tests/pg-replication-slot/src/test/java/org/apache/camel/quarkus/component/pg/replication/slot/it/PgReplicationSlotTestResource.java
@@ -41,14 +41,14 @@ public class PgReplicationSlotTestResource implements QuarkusTestResourceLifecyc
     private static final String POSTGRES_PASSWORD = "postgres-password";
     private static final String POSTGRES_USER = "postgres-user";
 
-    private GenericContainer pgContainer;
+    private GenericContainer<?> pgContainer;
 
     @Override
     public Map<String, String> start() {
         LOG.info(TestcontainersConfiguration.getInstance().toString());
 
         // Setup the Postgres container with replication enabled
-        pgContainer = new GenericContainer(POSTGRES_IMAGE).withCommand("postgres -c wal_level=logical")
+        pgContainer = new GenericContainer<>(POSTGRES_IMAGE).withCommand("postgres -c wal_level=logical")
                 .withExposedPorts(POSTGRES_PORT).withEnv("POSTGRES_USER", POSTGRES_USER)
                 .withEnv("POSTGRES_PASSWORD", POSTGRES_PASSWORD).withEnv("POSTGRES_DB", POSTGRES_DB_NAME)
                 .withLogConsumer(new Slf4jLogConsumer(LOG)).waitingFor(Wait.forListeningPort());