[camel-quarkus] 01/05: Forward HBase testcontainer's log to stdout to see whether #2458 is occurring

[ppalaga]

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

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

commit 96eb4bee3e16828238cfd29b078e5736ef4c2317
Author: Peter Palaga <ppal...@redhat.com>
AuthorDate: Fri Apr 9 09:59:08 2021 +0200

    Forward HBase testcontainer's log to stdout to see whether #2458 is 
occurring
---
 .../apache/camel/quarkus/component/hbase/it/HBaseTestResource.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/extensions-jvm/hbase/integration-test/src/test/java/org/apache/camel/quarkus/component/hbase/it/HBaseTestResource.java
 
b/extensions-jvm/hbase/integration-test/src/test/java/org/apache/camel/quarkus/component/hbase/it/HBaseTestResource.java
index 14664b6..fc7c27a 100644
--- 
a/extensions-jvm/hbase/integration-test/src/test/java/org/apache/camel/quarkus/component/hbase/it/HBaseTestResource.java
+++ 
b/extensions-jvm/hbase/integration-test/src/test/java/org/apache/camel/quarkus/component/hbase/it/HBaseTestResource.java
@@ -29,7 +29,7 @@ public class HBaseTestResource implements 
QuarkusTestResourceLifecycleManager {
     // must be the same as in the config of camel component
     static final Integer CLIENT_PORT = 2181;
 
-    private GenericContainer container;
+    private GenericContainer<?> container;
 
     @Override
     public Map<String, String> start() {
@@ -38,9 +38,10 @@ public class HBaseTestResource implements 
QuarkusTestResourceLifecycleManager {
             //there is only one tag for this docker image -  latest. See 
https://hub.docker.com/r/dajobe/hbase/tags
             //Hbase is using zookeeper. Hbase client gets location of hbase 
master from zookeeper, which means that
             //location uses internal hostnames from the docker.  Network mode 
`host` is the only way how to avoid
-            //manipulation with the hosts configuration at the test server. 
-            container = new GenericContainer("dajobe/hbase:latest")
+            //manipulation with the hosts configuration at the test server.
+            container = new GenericContainer<>("dajobe/hbase:latest")
                     .withNetworkMode("host")
+                    .withLogConsumer(frame -> 
System.out.print(frame.getUtf8String()))
                     .waitingFor(
                             Wait.forLogMessage(".*Finished refreshing block 
distribution cache for 2 regions\\n", 1));
             container.start();