[camel] 01/01: Just for debugging purpose

[nf...@apache.org]

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

nfilotto pushed a commit to branch CAMEL-17952/fix-hazelcast-tests
in repository https://gitbox.apache.org/repos/asf/camel.git

commit d34e10ce52dc5bdb217819063241b4e3d19e80c3
Author: Nicolas Filotto <nf...@talend.com>
AuthorDate: Wed Apr 13 19:40:42 2022 +0200

    Just for debugging purpose
---
 .github/workflows/master-pr-build.yml                    | 16 ++++++++--------
 .../hazelcast/queue/HazelcastQueueConsumer.java          |  9 ++++++++-
 .../hazelcast/HazelcastQueueConsumerPollTest.java        |  1 +
 3 files changed, 17 insertions(+), 9 deletions(-)

diff --git a/.github/workflows/master-pr-build.yml b/.github/workflows/master-pr-build.yml
index 0c2f69f49cd..ae7730572f7 100644
--- a/.github/workflows/master-pr-build.yml
+++ b/.github/workflows/master-pr-build.yml
@@ -71,14 +71,14 @@ jobs:
           distribution: 'temurin'
           java-version: ${{ matrix.java }}
           cache: 'maven'
-      - name: maven build
-        run: ${{ steps.install-mvnd.outputs.mvnd-dir }}/mvnd -l build.log -Dmvnd.threads=2 -V -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120 --no-transfer-progress -Pfastinstall -Dcheckstyle.skip=true -DskipTests install
-      - name: archive logs
-        uses: actions/upload-artifact@v3
-        if: always()
-        with:
-          name: build.log
-          path: build.log
+#      - name: maven build
+#        run: ${{ steps.install-mvnd.outputs.mvnd-dir }}/mvnd -l build.log -Dmvnd.threads=2 -V -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120 --no-transfer-progress -Pfastinstall -Dcheckstyle.skip=true -DskipTests install
+#      - name: archive logs
+#        uses: actions/upload-artifact@v3
+#        if: always()
+#        with:
+#          name: build.log
+#          path: build.log
       - id: test
         name: Quick test execution for affected components
         uses: ./.github/actions/quick-test
diff --git a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
index e177126b1ae..b4122480acf 100644
--- a/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
+++ b/components/camel-hazelcast/src/main/java/org/apache/camel/component/hazelcast/queue/HazelcastQueueConsumer.java
@@ -39,16 +39,21 @@ public class HazelcastQueueConsumer extends HazelcastDefaultConsumer {
         super(hazelcastInstance, endpoint, processor, cacheName);
         this.processor = processor;
         this.config = configuration;
+        System.out.println("HazelcastQueueConsumer hazelcastInstance = " + hazelcastInstance);
     }
 
     @Override
     protected void doStart() throws Exception {
+        System.out.println("1.doStart");
         super.doStart();
+        System.out.println("2.doStart");
         executor = ((HazelcastQueueEndpoint) getEndpoint()).createExecutor();
-
+        System.out.println("3.doStart");
         CamelItemListener camelItemListener = new CamelItemListener(this, cacheName);
+        System.out.println("4.doStart");
         queueConsumerTask = new QueueConsumerTask(camelItemListener);
         executor.submit(queueConsumerTask);
+        System.out.println("5.doStart");
     }
 
     @Override
@@ -75,7 +80,9 @@ public class HazelcastQueueConsumer extends HazelcastDefaultConsumer {
 
         @Override
         public void run() {
+            System.out.println("1.run");
             IQueue<Object> queue = hazelcastInstance.getQueue(cacheName);
+            System.out.println("2.run hazelcastInstance = " + hazelcastInstance);
             if (config.getQueueConsumerMode() == HazelcastQueueConsumerMode.LISTEN) {
                 queue.addItemListener(camelItemListener, true);
             }
diff --git a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerPollTest.java b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerPollTest.java
index d7f30406221..fdfd40feb49 100644
--- a/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerPollTest.java
+++ b/components/camel-hazelcast/src/test/java/org/apache/camel/component/hazelcast/HazelcastQueueConsumerPollTest.java
@@ -43,6 +43,7 @@ public class HazelcastQueueConsumerPollTest extends HazelcastCamelTestSupport {
     @Override
     protected void trainHazelcastInstance(HazelcastInstance hazelcastInstance) {
         when(hazelcastInstance.<String> getQueue("foo")).thenReturn(queue);
+        System.out.println("trainHazelcastInstance hazelcastInstance = " + hazelcastInstance);
     }
 
     @Override