You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by nf...@apache.org on 2022/04/13 17:41:12 UTC
[camel] branch CAMEL-17952/fix-hazelcast-tests created (now d34e10ce52d)
This is an automated email from the ASF dual-hosted git repository.
nfilotto pushed a change to branch CAMEL-17952/fix-hazelcast-tests
in repository https://gitbox.apache.org/repos/asf/camel.git
at d34e10ce52d Just for debugging purpose
This branch includes the following new commits:
new d34e10ce52d Just for debugging purpose
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel] 01/01: Just for debugging purpose
Posted by 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