This is an automated email from the ASF dual-hosted git repository.
pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 955329117407 chore(components): suppress warnings in deprecated
component tests
955329117407 is described below
commit 955329117407f527857128522574b14184e28b3a
Author: Pasquale Congiusti <[email protected]>
AuthorDate: Mon Nov 17 10:36:32 2025 +0100
chore(components): suppress warnings in deprecated component tests
Ref CAMEL-22549
---
.../impl/cloud/CombinedServiceDiscoveryTest.java | 2 +
.../impl/cloud/CombinedServiceFilterTest.java | 2 +
.../apache/camel/impl/cloud/LoadBalancerTest.java | 98 ++++++++++++----------
.../impl/cloud/ServiceCallConfigurationTest.java | 8 ++
.../camel/impl/cloud/ServiceDefinitionTest.java | 2 +
.../camel/impl/cloud/ServiceRegistryTest.java | 2 +
6 files changed, 68 insertions(+), 46 deletions(-)
diff --git
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/CombinedServiceDiscoveryTest.java
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/CombinedServiceDiscoveryTest.java
index 842f7bdd1c5d..3dbad0a7b1ab 100644
---
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/CombinedServiceDiscoveryTest.java
+++
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/CombinedServiceDiscoveryTest.java
@@ -25,6 +25,8 @@ import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertEquals;
+// The API is deprecated, we can remove warnings safely as the tests will
disappear when removing this component.
+@SuppressWarnings("deprecation")
public class CombinedServiceDiscoveryTest extends ContextTestSupport {
@Test
diff --git
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/CombinedServiceFilterTest.java
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/CombinedServiceFilterTest.java
index 6abe51c767a7..557d0cab1516 100644
---
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/CombinedServiceFilterTest.java
+++
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/CombinedServiceFilterTest.java
@@ -31,6 +31,8 @@ import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertInstanceOf;
import static org.junit.jupiter.api.Assertions.assertTrue;
+// The API is deprecated, we can remove warnings safely as the tests will
disappear when removing this component.
+@SuppressWarnings("deprecation")
public class CombinedServiceFilterTest extends ContextTestSupport {
@Test
public void testMultiServiceFilterConfiguration() throws Exception {
diff --git
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java
index 55f3e3533aee..58fb1962da59 100644
---
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java
+++
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/LoadBalancerTest.java
@@ -16,6 +16,7 @@
*/
package org.apache.camel.impl.cloud;
+import java.io.IOException;
import java.util.Collections;
import java.util.concurrent.RejectedExecutionException;
@@ -30,6 +31,8 @@ import static java.util.Optional.ofNullable;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertThrows;
+// The API is deprecated, we can remove warnings safely as the tests will
disappear when removing this component.
+@SuppressWarnings("deprecation")
public class LoadBalancerTest {
private static final StaticServiceDiscovery serviceDiscovery = new
StaticServiceDiscovery();
@@ -46,58 +49,61 @@ public class LoadBalancerTest {
@Test
public void testLoadBalancer() throws Exception {
- DefaultServiceLoadBalancer loadBalancer = new
DefaultServiceLoadBalancer();
- CamelContext camelContext = new DefaultCamelContext();
- loadBalancer.setCamelContext(camelContext);
- loadBalancer.setServiceDiscovery(serviceDiscovery);
- loadBalancer
- .setServiceFilter(
- (exchange, services) -> services.stream().filter(s ->
s.getPort() < 2000).toList());
- loadBalancer.setServiceChooser(new RoundRobinServiceChooser());
- Exchange exchange = new DefaultExchange(camelContext);
- loadBalancer.process(exchange, "no-name", service -> {
- assertEquals(1001, service.getPort());
- return false;
- });
- loadBalancer.process(exchange, "no-name", service -> {
- assertEquals(1002, service.getPort());
- return false;
- });
+ try (DefaultServiceLoadBalancer loadBalancer = new
DefaultServiceLoadBalancer()) {
+ CamelContext camelContext = new DefaultCamelContext();
+ loadBalancer.setCamelContext(camelContext);
+ loadBalancer.setServiceDiscovery(serviceDiscovery);
+ loadBalancer
+ .setServiceFilter(
+ (exchange, services) -> services.stream().filter(s
-> s.getPort() < 2000).toList());
+ loadBalancer.setServiceChooser(new RoundRobinServiceChooser());
+ Exchange exchange = new DefaultExchange(camelContext);
+ loadBalancer.process(exchange, "no-name", service -> {
+ assertEquals(1001, service.getPort());
+ return false;
+ });
+ loadBalancer.process(exchange, "no-name", service -> {
+ assertEquals(1002, service.getPort());
+ return false;
+ });
+ }
}
@Test
public void testLoadBalancerWithContentBasedServiceFilter() throws
Exception {
- DefaultServiceLoadBalancer loadBalancer = new
DefaultServiceLoadBalancer();
- loadBalancer.setCamelContext(new DefaultCamelContext());
- loadBalancer.setServiceDiscovery(serviceDiscovery);
- loadBalancer.setServiceFilter(
- (exchange, services) -> services.stream()
- .filter(serviceDefinition ->
ofNullable(serviceDefinition.getMetadata()
- .get("supports"))
- .orElse("")
- .contains(exchange.getProperty("needs",
String.class)))
- .toList());
- loadBalancer.setServiceChooser(new RoundRobinServiceChooser());
- Exchange exchange = new DefaultExchange(new DefaultCamelContext());
- exchange.setProperty("needs", "foo");
- loadBalancer.process(exchange, "no-name", service -> {
- assertEquals(1003, service.getPort());
- return false;
- });
+ try (DefaultServiceLoadBalancer loadBalancer = new
DefaultServiceLoadBalancer()) {
+ loadBalancer.setCamelContext(new DefaultCamelContext());
+ loadBalancer.setServiceDiscovery(serviceDiscovery);
+ loadBalancer.setServiceFilter(
+ (exchange, services) -> services.stream()
+ .filter(serviceDefinition ->
ofNullable(serviceDefinition.getMetadata()
+ .get("supports"))
+ .orElse("")
+ .contains(exchange.getProperty("needs",
String.class)))
+ .toList());
+ loadBalancer.setServiceChooser(new RoundRobinServiceChooser());
+ Exchange exchange = new DefaultExchange(new DefaultCamelContext());
+ exchange.setProperty("needs", "foo");
+ loadBalancer.process(exchange, "no-name", service -> {
+ assertEquals(1003, service.getPort());
+ return false;
+ });
+ }
}
@Test
- public void testNoActiveServices() {
- DefaultServiceLoadBalancer loadBalancer = new
DefaultServiceLoadBalancer();
- DefaultCamelContext camelContext = new DefaultCamelContext();
- loadBalancer.setCamelContext(camelContext);
- loadBalancer.setServiceDiscovery(serviceDiscovery);
- loadBalancer
- .setServiceFilter(
- (exchange, services) -> services.stream().filter(s ->
s.getPort() < 1000).toList());
- loadBalancer.setServiceChooser(new RoundRobinServiceChooser());
- assertThrows(RejectedExecutionException.class, () -> {
- loadBalancer.process(new DefaultExchange(camelContext), "no-name",
service -> false);
- });
+ public void testNoActiveServices() throws IOException {
+ try (DefaultServiceLoadBalancer loadBalancer = new
DefaultServiceLoadBalancer()) {
+ DefaultCamelContext camelContext = new DefaultCamelContext();
+ loadBalancer.setCamelContext(camelContext);
+ loadBalancer.setServiceDiscovery(serviceDiscovery);
+ loadBalancer
+ .setServiceFilter(
+ (exchange, services) -> services.stream().filter(s
-> s.getPort() < 1000).toList());
+ loadBalancer.setServiceChooser(new RoundRobinServiceChooser());
+ assertThrows(RejectedExecutionException.class, () -> {
+ loadBalancer.process(new DefaultExchange(camelContext),
"no-name", service -> false);
+ });
+ }
}
}
diff --git
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceCallConfigurationTest.java
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceCallConfigurationTest.java
index 831e0ccf451d..9fece3b0e037 100644
---
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceCallConfigurationTest.java
+++
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceCallConfigurationTest.java
@@ -39,6 +39,8 @@ import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertInstanceOf;
import static org.junit.jupiter.api.Assertions.assertNotNull;
+// The API is deprecated, we can remove warnings safely as the tests will
disappear when removing this component.
+@SuppressWarnings("deprecation")
public class ServiceCallConfigurationTest {
// ****************************************
@@ -86,6 +88,7 @@ public class ServiceCallConfigurationTest {
mock.assertIsSatisfied();
context.stop();
+ context.close();
}
@Test
@@ -127,6 +130,7 @@ public class ServiceCallConfigurationTest {
assertEquals(sf, loadBalancer.getServiceFilter());
context.stop();
+ context.close();
}
@Test
@@ -169,6 +173,7 @@ public class ServiceCallConfigurationTest {
assertEquals(sf, loadBalancer.getServiceFilter());
context.stop();
+ context.close();
}
@Test
@@ -211,6 +216,7 @@ public class ServiceCallConfigurationTest {
assertEquals(sf, loadBalancer.getServiceFilter());
context.stop();
+ context.close();
}
// ****************************************
@@ -316,6 +322,7 @@ public class ServiceCallConfigurationTest {
}
context.stop();
+ context.close();
}
// **********************************************
@@ -439,6 +446,7 @@ public class ServiceCallConfigurationTest {
}
context.stop();
+ context.close();
}
// **********************************************
diff --git
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceDefinitionTest.java
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceDefinitionTest.java
index 0beb70cc26c9..b4aac9a28772 100644
---
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceDefinitionTest.java
+++
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceDefinitionTest.java
@@ -27,6 +27,8 @@ import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
+// The API is deprecated, we can remove warnings safely as the tests will
disappear when removing this component.
+@SuppressWarnings("deprecation")
public class ServiceDefinitionTest {
@Test
public void testParse() {
diff --git
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceRegistryTest.java
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceRegistryTest.java
index e5ff5c718751..840055bce45b 100644
---
a/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceRegistryTest.java
+++
b/core/camel-cloud/src/test/java/org/apache/camel/impl/cloud/ServiceRegistryTest.java
@@ -30,6 +30,8 @@ import org.junit.jupiter.api.Test;
import static org.assertj.core.api.Assertions.assertThat;
+// The API is deprecated, we can remove warnings safely as the tests will
disappear when removing this component.
+@SuppressWarnings("deprecation")
public class ServiceRegistryTest extends ContextTestSupport {
// *********************
