You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2024/12/30 15:40:17 UTC
(camel) branch main updated (8e2b0be35f0 -> 630218652c2)
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from 8e2b0be35f0 CAMEL-21503: remove the tools feature from the chat component
new 2f03fddc283 (chores) camel-infinispan: avoid affecting the stop if the cache manager is unstarted
new 5bcc55e580c (chores) camel-infinispan: disable unreliable tests
new 94489dbbd50 (chores) camel-core: disable unreliable tests on VMs
new 630218652c2 (chores) camel-platform-http: disable broken test
The 4 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.
Summary of changes:
.../infinispan/remote/InfinispanRemoteConsumer.java | 15 ++++++++++++++-
.../infinispan/remote/InfinispanRemoteConsumerIT.java | 3 +++
.../remote/InfinispanRemoteCustomListenerIT.java | 3 +++
.../component/platform/http/PlatformHttpProxyTest.java | 2 ++
.../MulticastParallelTimeoutStreamCachingTest.java | 2 +-
5 files changed, 23 insertions(+), 2 deletions(-)
(camel) 03/04: (chores) camel-core: disable unreliable tests on VMs
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 94489dbbd5018472a06a432c57f9d3babc3c5439
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Dec 30 15:03:25 2024 +0100
(chores) camel-core: disable unreliable tests on VMs
---
.../camel/processor/MulticastParallelTimeoutStreamCachingTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelTimeoutStreamCachingTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelTimeoutStreamCachingTest.java
index 6b7040a93b0..9f38d47a36d 100644
--- a/core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelTimeoutStreamCachingTest.java
+++ b/core/camel-core/src/test/java/org/apache/camel/processor/MulticastParallelTimeoutStreamCachingTest.java
@@ -39,7 +39,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
/**
*
*/
-@DisabledIfSystemProperty(named = "ci.env.name", matches = "github.com", disabledReason = "Flaky on Github CI")
+@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*", disabledReason = "Unreliable on virtual machines")
@DisabledOnOs(architectures = { "s390x" },
disabledReason = "This test does not run reliably on s390x")
public class MulticastParallelTimeoutStreamCachingTest extends ContextTestSupport {
(camel) 02/04: (chores) camel-infinispan: disable unreliable tests
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 5bcc55e580c96e692905436d6850f65be642b703
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Dec 30 14:56:57 2024 +0100
(chores) camel-infinispan: disable unreliable tests
---
.../camel/component/infinispan/remote/InfinispanRemoteConsumerIT.java | 3 +++
.../component/infinispan/remote/InfinispanRemoteCustomListenerIT.java | 3 +++
2 files changed, 6 insertions(+)
diff --git a/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteConsumerIT.java b/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteConsumerIT.java
index 51fed12d7d1..5077e32dd0b 100644
--- a/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteConsumerIT.java
+++ b/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteConsumerIT.java
@@ -23,7 +23,10 @@ import org.apache.camel.component.mock.MockEndpoint;
import org.infinispan.commons.api.BasicCache;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
+@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
+ disabledReason = "Extremely unreliable on virtual machines")
public class InfinispanRemoteConsumerIT extends InfinispanRemoteTestSupport implements InfinispanConsumerTestSupport {
@Test
public void consumerReceivedEventNotifications() throws Exception {
diff --git a/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteCustomListenerIT.java b/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteCustomListenerIT.java
index abdf0b2b5bb..dd97d54d74c 100644
--- a/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteCustomListenerIT.java
+++ b/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteCustomListenerIT.java
@@ -27,7 +27,10 @@ import org.infinispan.client.hotrod.event.ClientCacheEntryCreatedEvent;
import org.infinispan.commons.api.BasicCache;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.condition.DisabledIfSystemProperty;
+@DisabledIfSystemProperty(named = "ci.env.name", matches = ".*",
+ disabledReason = "Extremely unreliable on virtual machines")
public class InfinispanRemoteCustomListenerIT extends InfinispanRemoteTestSupport implements InfinispanConsumerTestSupport {
@Test
public void consumerReceivedEventNotifications() throws Exception {
(camel) 01/04: (chores) camel-infinispan: avoid affecting the stop if the cache manager is unstarted
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2f03fddc2837a44ed85655e18421da227bd90bfc
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Dec 30 14:49:01 2024 +0100
(chores) camel-infinispan: avoid affecting the stop if the cache manager is unstarted
---
.../infinispan/remote/InfinispanRemoteConsumer.java | 15 ++++++++++++++-
1 file changed, 14 insertions(+), 1 deletion(-)
diff --git a/components/camel-infinispan/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteConsumer.java b/components/camel-infinispan/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteConsumer.java
index 45a4db3894b..7e8de630142 100644
--- a/components/camel-infinispan/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteConsumer.java
+++ b/components/camel-infinispan/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/remote/InfinispanRemoteConsumer.java
@@ -31,12 +31,17 @@ import org.infinispan.client.hotrod.RemoteCache;
import org.infinispan.client.hotrod.RemoteCacheManager;
import org.infinispan.client.hotrod.Search;
import org.infinispan.client.hotrod.event.ClientEvent;
+import org.infinispan.client.hotrod.exceptions.RemoteCacheManagerNotStartedException;
import org.infinispan.query.api.continuous.ContinuousQuery;
import org.infinispan.query.api.continuous.ContinuousQueryListener;
import org.infinispan.query.dsl.Query;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
public class InfinispanRemoteConsumer
extends InfinispanConsumer<RemoteCacheManager, InfinispanRemoteManager, InfinispanRemoteConfiguration> {
+ private static final Logger LOG = LoggerFactory.getLogger(InfinispanRemoteConsumer.class);
+
private Service handler;
public InfinispanRemoteConsumer(
@@ -141,7 +146,15 @@ public class InfinispanRemoteConsumer
@SuppressWarnings("unchecked")
@Override
public void doStop() {
- getCache(RemoteCache.class).removeClientListener(listener);
+ final RemoteCache cache = getCache(RemoteCache.class);
+ if (cache != null) {
+ try {
+ cache.removeClientListener(listener);
+ } catch (RemoteCacheManagerNotStartedException e) {
+ LOG.debug("Cannot remote the listener because the cache manager is not started: {}", e.getMessage(), e);
+ }
+ }
+
}
}
(camel) 04/04: (chores) camel-platform-http: disable broken test
Posted by or...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 630218652c2298b960c0f0a769d0369ce502a14e
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Dec 30 15:15:27 2024 +0100
(chores) camel-platform-http: disable broken test
The test tries to access an invalid URL which causes it to fail
---
.../org/apache/camel/component/platform/http/PlatformHttpProxyTest.java | 2 ++
1 file changed, 2 insertions(+)
diff --git a/components/camel-platform-http/src/test/java/org/apache/camel/component/platform/http/PlatformHttpProxyTest.java b/components/camel-platform-http/src/test/java/org/apache/camel/component/platform/http/PlatformHttpProxyTest.java
index c25da3058cd..c35d51d85df 100644
--- a/components/camel-platform-http/src/test/java/org/apache/camel/component/platform/http/PlatformHttpProxyTest.java
+++ b/components/camel-platform-http/src/test/java/org/apache/camel/component/platform/http/PlatformHttpProxyTest.java
@@ -19,11 +19,13 @@ package org.apache.camel.component.platform.http;
import io.restassured.http.ContentType;
import org.apache.camel.Exchange;
import org.apache.camel.builder.RouteBuilder;
+import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import static io.restassured.RestAssured.given;
import static org.hamcrest.Matchers.containsString;
+@Disabled("Broken test: fails due to invalid host")
public class PlatformHttpProxyTest extends AbstractPlatformHttpTest {
@Test
void testProxy() {