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
The following commit(s) were added to refs/heads/main by this push:
new 0139562ecae (chores) camel-components: use unmodifiable lists when
possible (#11395)
0139562ecae is described below
commit 0139562ecaeb90924d07d756053f228d04dd61a3
Author: Otavio Rodolfo Piske <orpi...@users.noreply.github.com>
AuthorDate: Thu Sep 14 12:56:26 2023 +0200
(chores) camel-components: use unmodifiable lists when possible (#11395)
---
.../test/java/org/apache/camel/component/aws/xray/TestUtils.java | 5 ++---
.../component/azure/cosmosdb/integration/CosmosDbProducerIT.java | 3 +--
.../azure/servicebus/integration/ServiceBusProducerTest.java | 3 +--
.../component/azure/storage/blob/integration/BlobOperationsIT.java | 3 +--
.../azure/storage/blob/operations/BlobContainerOperationsTest.java | 5 ++---
.../datalake/operations/DataLakeFileSystemOperationTest.java | 6 +++---
.../storage/queue/operations/integration/QueueOperationsIT.java | 5 ++---
.../queue/operations/integration/QueueServiceOperationsIT.java | 3 +--
.../consul/cluster/ConsulClusteredRoutePolicyFactoryIT.java | 3 +--
.../component/consul/cluster/ConsulClusteredRoutePolicyIT.java | 3 +--
.../org/apache/camel/component/consul/cluster/ConsulMasterIT.java | 3 +--
.../java/org/apache/camel/dataformat/csv/CsvMarshalHeaderTest.java | 5 ++---
.../csv/CsvMarshalHeaderWithCustomMarshallFactoryTest.java | 3 +--
.../org/apache/camel/component/cxf/jaxws/CxfProducerRouterTest.java | 3 +--
.../remote/cluster/AbstractInfinispanRemoteClusteredIT.java | 3 +--
.../camel/component/jgroups/cluster/JGroupsLockMasterTest.java | 3 +--
.../java/org/apache/camel/component/kafka/KafkaProducerTest.java | 2 +-
.../apache/camel/component/knative/spi/KnativeEnvironmentTest.java | 2 +-
.../component/kubernetes/cluster/KubernetesClusterServiceTest.java | 4 ++--
.../java/org/apache/camel/component/master/MasterComponentTest.java | 3 +--
.../org/apache/camel/component/nitrite/AbstractNitriteTest.java | 3 +--
.../apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java | 3 +--
.../camel/component/pulsar/integration/PulsarSuspendRouteIT.java | 3 +--
.../camel/component/reactive/streams/ConcurrentConsumersTest.java | 2 +-
.../org/apache/camel/spring/health/HealthCheckRegistryTest.java | 3 +--
.../org/apache/camel/component/telegram/TelegramChatBotTest.java | 2 +-
.../component/telegram/TelegramConsumerFallbackConversionTest.java | 3 +--
.../cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java | 3 +--
.../cluster/integration/ZooKeeperClusteredRoutePolicyIT.java | 3 +--
.../component/zookeeper/cluster/integration/ZooKeeperMasterIT.java | 3 +--
30 files changed, 37 insertions(+), 61 deletions(-)
diff --git
a/components/camel-aws/camel-aws-xray/src/test/java/org/apache/camel/component/aws/xray/TestUtils.java
b/components/camel-aws/camel-aws-xray/src/test/java/org/apache/camel/component/aws/xray/TestUtils.java
index 1e266d2186c..d81e2ae1467 100644
---
a/components/camel-aws/camel-aws-xray/src/test/java/org/apache/camel/component/aws/xray/TestUtils.java
+++
b/components/camel-aws/camel-aws-xray/src/test/java/org/apache/camel/component/aws/xray/TestUtils.java
@@ -19,7 +19,6 @@ package org.apache.camel.component.aws.xray;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
-import java.util.stream.Collectors;
import org.apache.camel.component.aws.xray.TestDataBuilder.TestSegment;
import org.apache.camel.component.aws.xray.TestDataBuilder.TestSubsegment;
@@ -49,8 +48,8 @@ public final class TestUtils {
private static void verifyTraces(TestTrace expected, TestTrace actual) {
assertThat("Incorrect number of segment for trace. Expected traces: "
- + expected.getSegments().stream().map(s ->
s.name).collect(Collectors.toList())
- + " but found " + actual.getSegments().stream().map(s ->
s.name).collect(Collectors.toList()),
+ + expected.getSegments().stream().map(s -> s.name).toList()
+ + " but found " + actual.getSegments().stream().map(s ->
s.name).toList(),
actual.getSegments().size(),
is(equalTo(expected.getSegments().size())));
List<TestSegment> expectedSegments = new
ArrayList<>(expected.getSegments());
List<TestSegment> actualSegments = new
ArrayList<>(actual.getSegments());
diff --git
a/components/camel-azure/camel-azure-cosmosdb/src/test/java/org/apache/camel/component/azure/cosmosdb/integration/CosmosDbProducerIT.java
b/components/camel-azure/camel-azure-cosmosdb/src/test/java/org/apache/camel/component/azure/cosmosdb/integration/CosmosDbProducerIT.java
index b8f2d0d1a25..743658654a2 100644
---
a/components/camel-azure/camel-azure-cosmosdb/src/test/java/org/apache/camel/component/azure/cosmosdb/integration/CosmosDbProducerIT.java
+++
b/components/camel-azure/camel-azure-cosmosdb/src/test/java/org/apache/camel/component/azure/cosmosdb/integration/CosmosDbProducerIT.java
@@ -19,7 +19,6 @@ package org.apache.camel.component.azure.cosmosdb.integration;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import java.util.stream.Collectors;
import com.azure.cosmos.models.CosmosContainerProperties;
import com.azure.cosmos.models.CosmosDatabaseProperties;
@@ -87,7 +86,7 @@ public class CosmosDbProducerIT extends
BaseCamelCosmosDbTestSupport {
final List<String> returnedDatabasesAsString = returnedDatabases
.stream().map(CosmosDatabaseProperties::getId)
- .collect(Collectors.toList());
+ .toList();
assertEquals(5, returnedDatabasesAsString.size());
diff --git
a/components/camel-azure/camel-azure-servicebus/src/test/java/org/apache/camel/component/azure/servicebus/integration/ServiceBusProducerTest.java
b/components/camel-azure/camel-azure-servicebus/src/test/java/org/apache/camel/component/azure/servicebus/integration/ServiceBusProducerTest.java
index 020da67fa0d..419251207e4 100644
---
a/components/camel-azure/camel-azure-servicebus/src/test/java/org/apache/camel/component/azure/servicebus/integration/ServiceBusProducerTest.java
+++
b/components/camel-azure/camel-azure-servicebus/src/test/java/org/apache/camel/component/azure/servicebus/integration/ServiceBusProducerTest.java
@@ -21,7 +21,6 @@ import java.util.LinkedList;
import java.util.List;
import java.util.Map;
import java.util.Spliterator;
-import java.util.stream.Collectors;
import java.util.stream.StreamSupport;
import com.azure.messaging.servicebus.ServiceBusReceivedMessage;
@@ -58,7 +57,7 @@ class ServiceBusProducerTest extends
BaseCamelServiceBusTestSupport {
// let's check our data
final List<ServiceBusReceivedMessage> receivedMessages
- =
receiverAsyncClient.receiveMessages().toStream().collect(Collectors.toList());
+ = receiverAsyncClient.receiveMessages().toStream().toList();
final boolean batch1Exists = receivedMessages.stream()
.anyMatch(serviceBusReceivedMessage ->
serviceBusReceivedMessage.getBody().toString().equals("123456789"));
diff --git
a/components/camel-azure/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobOperationsIT.java
b/components/camel-azure/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobOperationsIT.java
index b3f1dfccc25..8d1b3d05146 100644
---
a/components/camel-azure/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobOperationsIT.java
+++
b/components/camel-azure/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/integration/BlobOperationsIT.java
@@ -31,7 +31,6 @@ import java.security.SecureRandom;
import java.util.LinkedList;
import java.util.List;
import java.util.Objects;
-import java.util.stream.Collectors;
import com.azure.core.http.rest.PagedIterable;
import com.azure.storage.blob.models.PageRange;
@@ -447,7 +446,7 @@ class BlobOperationsIT extends Base {
assertNotNull(response);
final PagedIterable<?> pagedIterable = (PagedIterable<?>)
response.getBody();
- List<?> pageRangeItems =
pagedIterable.stream().collect(Collectors.toList());
+ List<?> pageRangeItems = pagedIterable.stream().toList();
assertEquals(1, pageRangeItems.size());
assertInstanceOf(PageRangeItem.class, pageRangeItems.get(0));
diff --git
a/components/camel-azure/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/operations/BlobContainerOperationsTest.java
b/components/camel-azure/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/operations/BlobContainerOperationsTest.java
index 9f0a891e575..cdfe3173a61 100644
---
a/components/camel-azure/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/operations/BlobContainerOperationsTest.java
+++
b/components/camel-azure/camel-azure-storage-blob/src/test/java/org/apache/camel/component/azure/storage/blob/operations/BlobContainerOperationsTest.java
@@ -18,7 +18,6 @@ package
org.apache.camel.component.azure.storage.blob.operations;
import java.util.LinkedList;
import java.util.List;
-import java.util.stream.Collectors;
import com.azure.core.http.HttpHeaders;
import com.azure.storage.blob.models.BlobItem;
@@ -89,7 +88,7 @@ class BlobContainerOperationsTest {
@SuppressWarnings("unchecked")
final List<BlobItem> body = (List<BlobItem>) response.getBody();
- final List<String> items =
body.stream().map(BlobItem::getName).collect(Collectors.toList());
+ final List<String> items =
body.stream().map(BlobItem::getName).toList();
assertTrue(items.contains("item-1"));
assertTrue(items.contains("item-2"));
@@ -112,7 +111,7 @@ class BlobContainerOperationsTest {
@SuppressWarnings("unchecked")
final List<BlobItem> body = (List<BlobItem>) response.getBody();
- final List<String> items =
body.stream().map(BlobItem::getName).collect(Collectors.toList());
+ final List<String> items =
body.stream().map(BlobItem::getName).toList();
assertEquals(3, items.size());
assertTrue(items.contains("invoice1.pdf"));
assertTrue(items.contains("invoice2.pdf"));
diff --git
a/components/camel-azure/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/operations/DataLakeFileSystemOperationTest.java
b/components/camel-azure/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/operations/DataLakeFileSystemOperationTest.java
index a2801be9f85..eee0364982b 100644
---
a/components/camel-azure/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/operations/DataLakeFileSystemOperationTest.java
+++
b/components/camel-azure/camel-azure-storage-datalake/src/test/java/org/apache/camel/component/azure/storage/datalake/operations/DataLakeFileSystemOperationTest.java
@@ -93,12 +93,12 @@ public class DataLakeFileSystemOperationTest extends
CamelTestSupport {
@SuppressWarnings("unchecked")
final List<PathItem> body = (List<PathItem>) response.getBody();
- final List<String> pathNames =
body.stream().map(PathItem::getName).collect(Collectors.toList());
+ final List<String> pathNames =
body.stream().map(PathItem::getName).toList();
assertTrue(pathNames.contains("item1"));
assertTrue(pathNames.contains("item2"));
- final List<PathItem> directories =
body.stream().filter(PathItem::isDirectory).collect(Collectors.toList());
- final List<PathItem> files = body.stream().filter(pathItem ->
!pathItem.isDirectory()).collect(Collectors.toList());
+ final List<PathItem> directories =
body.stream().filter(PathItem::isDirectory).toList();
+ final List<PathItem> files = body.stream().filter(pathItem ->
!pathItem.isDirectory()).toList();
assertEquals(1, directories.size());
assertEquals(1, files.size());
}
diff --git
a/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/operations/integration/QueueOperationsIT.java
b/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/operations/integration/QueueOperationsIT.java
index 810eefc5dfc..c8f79669dbe 100644
---
a/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/operations/integration/QueueOperationsIT.java
+++
b/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/operations/integration/QueueOperationsIT.java
@@ -19,7 +19,6 @@ package
org.apache.camel.component.azure.storage.queue.operations.integration;
import java.time.Duration;
import java.util.List;
import java.util.Properties;
-import java.util.stream.Collectors;
import com.azure.storage.queue.QueueServiceClient;
import com.azure.storage.queue.models.PeekedMessageItem;
@@ -86,7 +85,7 @@ class QueueOperationsIT extends CamelTestSupport {
assertTrue(serviceClientWrapper.listQueues(null, null)
.stream()
.map(QueueItem::getName)
- .collect(Collectors.toList())
+ .toList()
.contains(queueName));
// delete and test
@@ -97,7 +96,7 @@ class QueueOperationsIT extends CamelTestSupport {
assertFalse(serviceClientWrapper.listQueues(null, null)
.stream()
.map(QueueItem::getName)
- .collect(Collectors.toList())
+ .toList()
.contains(queueName));
}
diff --git
a/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/operations/integration/QueueServiceOperationsIT.java
b/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/operations/integration/QueueServiceOperationsIT.java
index 818ee48c36f..9fcd0b2cf31 100644
---
a/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/operations/integration/QueueServiceOperationsIT.java
+++
b/components/camel-azure/camel-azure-storage-queue/src/test/java/org/apache/camel/component/azure/storage/queue/operations/integration/QueueServiceOperationsIT.java
@@ -18,7 +18,6 @@ package
org.apache.camel.component.azure.storage.queue.operations.integration;
import java.util.List;
import java.util.Properties;
-import java.util.stream.Collectors;
import com.azure.storage.queue.QueueServiceClient;
import com.azure.storage.queue.models.QueueItem;
@@ -86,7 +85,7 @@ class QueueServiceOperationsIT {
final List<String> queues = ((List<QueueItem>)
queuesResponse.getBody())
.stream()
.map(QueueItem::getName)
- .collect(Collectors.toList());
+ .toList();
assertTrue(queues.contains(queueName1));
assertTrue(queues.contains(queueName2));
diff --git
a/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyFactoryIT.java
b/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyFactoryIT.java
index 2ad16f87934..1f4a01c1664 100644
---
a/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyFactoryIT.java
+++
b/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyFactoryIT.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -43,7 +42,7 @@ public class ConsulClusteredRoutePolicyFactoryIT {
public static ConsulService service = ConsulServiceFactory.createService();
private static final Logger LOGGER =
LoggerFactory.getLogger(ConsulClusteredRoutePolicyFactoryIT.class);
- private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).toList();
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size() * 2);
private static final CountDownLatch LATCH = new
CountDownLatch(CLIENTS.size());
diff --git
a/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyIT.java
b/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyIT.java
index 37f11a327aa..6d68c736702 100644
---
a/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyIT.java
+++
b/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulClusteredRoutePolicyIT.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -43,7 +42,7 @@ public class ConsulClusteredRoutePolicyIT {
public static ConsulService service = ConsulServiceFactory.createService();
private static final Logger LOGGER =
LoggerFactory.getLogger(ConsulClusteredRoutePolicyIT.class);
- private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).toList();
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size() * 2);
private static final CountDownLatch LATCH = new
CountDownLatch(CLIENTS.size());
diff --git
a/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulMasterIT.java
b/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulMasterIT.java
index 4ab49a31017..1b6e16bfe56 100644
---
a/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulMasterIT.java
+++
b/components/camel-consul/src/test/java/org/apache/camel/component/consul/cluster/ConsulMasterIT.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -42,7 +41,7 @@ public class ConsulMasterIT {
public static ConsulService service = ConsulServiceFactory.createService();
private static final Logger LOGGER =
LoggerFactory.getLogger(ConsulMasterIT.class);
- private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).toList();
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size() * 2);
private static final CountDownLatch LATCH = new
CountDownLatch(CLIENTS.size());
diff --git
a/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvMarshalHeaderTest.java
b/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvMarshalHeaderTest.java
index a27bb00e3a9..0a0b0bc5ad3 100644
---
a/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvMarshalHeaderTest.java
+++
b/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvMarshalHeaderTest.java
@@ -25,7 +25,6 @@ import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
-import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.apache.camel.Exchange;
@@ -71,7 +70,7 @@ public class CsvMarshalHeaderTest extends CamelTestSupport {
producerTemplate.sendBodyAndHeader(body, Exchange.FILE_NAME, fileName);
try (Stream<String> stream = Files.lines(Paths.get(outputFile.toURI()))
.filter(l -> l.trim().length() > 0)) {
- List<String> lines = stream.collect(Collectors.toList());
+ List<String> lines = stream.toList();
// We got twice the headers... :(
assertEquals(4, lines.size());
}
@@ -87,7 +86,7 @@ public class CsvMarshalHeaderTest extends CamelTestSupport {
producerTemplate.sendBodyAndHeader(body, Exchange.FILE_NAME, fileName);
try (Stream<String> stream = Files.lines(Paths.get(outputFile.toURI()))
.filter(l -> l.trim().length() > 0)) {
- List<String> lines = stream.collect(Collectors.toList());
+ List<String> lines = stream.toList();
// We got twice the headers... :(
assertEquals(4, lines.size());
}
diff --git
a/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvMarshalHeaderWithCustomMarshallFactoryTest.java
b/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvMarshalHeaderWithCustomMarshallFactoryTest.java
index 1a8033adae6..b82ae35ee07 100644
---
a/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvMarshalHeaderWithCustomMarshallFactoryTest.java
+++
b/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvMarshalHeaderWithCustomMarshallFactoryTest.java
@@ -27,7 +27,6 @@ import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
-import java.util.stream.Collectors;
import java.util.stream.Stream;
import org.apache.camel.Exchange;
@@ -77,7 +76,7 @@ public class CsvMarshalHeaderWithCustomMarshallFactoryTest
extends CamelTestSupp
producerTemplate.sendBodyAndHeader(body, Exchange.FILE_NAME, fileName);
try (Stream<String> stream = Files.lines(Paths.get(outputFile.toURI()))
.filter(l -> l.trim().length() > 0)) {
- List<String> lines = stream.collect(Collectors.toList());
+ List<String> lines = stream.toList();
assertEquals(3, lines.size());
}
}
diff --git
a/components/camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/CxfProducerRouterTest.java
b/components/camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/CxfProducerRouterTest.java
index 82f9d6dd1e2..926e88dcce1 100644
---
a/components/camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/CxfProducerRouterTest.java
+++
b/components/camel-cxf/camel-cxf-soap/src/test/java/org/apache/camel/component/cxf/jaxws/CxfProducerRouterTest.java
@@ -19,7 +19,6 @@ package org.apache.camel.component.cxf.jaxws;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
-import java.util.stream.Collectors;
import org.apache.camel.Exchange;
import org.apache.camel.ExchangePattern;
@@ -161,7 +160,7 @@ public class CxfProducerRouterTest extends CamelTestSupport
{
org.apache.camel.Message out = exchange.getMessage();
final List<String> pseudoHeaders
- = out.getHeaders().keySet().stream().filter(key ->
key.startsWith(":")).collect(Collectors.toList());
+ = out.getHeaders().keySet().stream().filter(key ->
key.startsWith(":")).toList();
assertTrue(pseudoHeaders.isEmpty(), "Pseudo-headers such as :status
should be filtered out; found: " + pseudoHeaders);
}
diff --git
a/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/cluster/AbstractInfinispanRemoteClusteredIT.java
b/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/cluster/AbstractInfinispanRemoteClusteredIT.java
index 41f7404d332..0f3d7c30c7d 100644
---
a/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/cluster/AbstractInfinispanRemoteClusteredIT.java
+++
b/components/camel-infinispan/camel-infinispan/src/test/java/org/apache/camel/component/infinispan/remote/cluster/AbstractInfinispanRemoteClusteredIT.java
@@ -24,7 +24,6 @@ import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
import java.util.function.Function;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -72,7 +71,7 @@ public class AbstractInfinispanRemoteClusteredIT {
}
public void runTest(Function<RunnerEnv, RouteBuilder>
routeBuilderFunction) throws Exception {
- final List<String> clients = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ final List<String> clients = IntStream.range(0,
3).mapToObj(Integer::toString).toList();
final List<String> results = new ArrayList<>();
final CountDownLatch latch = new CountDownLatch(clients.size());
diff --git
a/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/cluster/JGroupsLockMasterTest.java
b/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/cluster/JGroupsLockMasterTest.java
index 8ddd98c9853..61aebd0286a 100644
---
a/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/cluster/JGroupsLockMasterTest.java
+++
b/components/camel-jgroups/src/test/java/org/apache/camel/component/jgroups/cluster/JGroupsLockMasterTest.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -37,7 +36,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class JGroupsLockMasterTest {
private static final Logger LOGGER =
LoggerFactory.getLogger(JGroupsLockMasterTest.class);
- private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).toList();
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size());
private static final CountDownLatch LATCH = new
CountDownLatch(CLIENTS.size());
diff --git
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
index 6633e4b3a08..7966e8108cd 100755
---
a/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
+++
b/components/camel-kafka/src/test/java/org/apache/camel/component/kafka/KafkaProducerTest.java
@@ -516,7 +516,7 @@ public class KafkaProducerTest {
Mockito.verify(producer.getKafkaProducer(),
Mockito.atLeast(expectedTopics.size())).send(captor.capture());
final List<ProducerRecord> records = captor.getAllValues();
final List<String> actualTopics
- =
records.stream().map(ProducerRecord::topic).collect(Collectors.toList());
+ = records.stream().map(ProducerRecord::topic).toList();
assertEquals(expectedTopics, actualTopics);
diff --git
a/components/camel-knative/camel-knative-api/src/test/java/org/apache/camel/component/knative/spi/KnativeEnvironmentTest.java
b/components/camel-knative/camel-knative-api/src/test/java/org/apache/camel/component/knative/spi/KnativeEnvironmentTest.java
index 8fc585eeaa4..4259c60653c 100644
---
a/components/camel-knative/camel-knative-api/src/test/java/org/apache/camel/component/knative/spi/KnativeEnvironmentTest.java
+++
b/components/camel-knative/camel-knative-api/src/test/java/org/apache/camel/component/knative/spi/KnativeEnvironmentTest.java
@@ -38,7 +38,7 @@ public class KnativeEnvironmentTest {
})
public void testKnativeEnvironmentDeserializationFromString(String
content) throws Exception {
KnativeEnvironment env =
KnativeEnvironment.mandatoryLoadFromSerializedString(content);
- List<KnativeResource> res = env.lookup(Knative.Type.endpoint,
"knative3").collect(Collectors.toList());
+ List<KnativeResource> res = env.lookup(Knative.Type.endpoint,
"knative3").toList();
assertThat(res).hasSize(1);
assertThat(res).first().satisfies(resource -> {
diff --git
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
index 4306c181004..4b37cbf1ea5 100644
---
a/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
+++
b/components/camel-kubernetes/src/test/java/org/apache/camel/component/kubernetes/cluster/KubernetesClusterServiceTest.java
@@ -112,7 +112,7 @@ public class KubernetesClusterServiceTest extends
CamelTestSupport {
public void testMultipleMembersLeaderElection(LeaseResourceType type) {
int number = 5;
List<LeaderRecorder> members
- = IntStream.range(0, number).mapToObj(i -> addMember("mypod" +
i, type)).collect(Collectors.toList());
+ = IntStream.range(0, number).mapToObj(i -> addMember("mypod" +
i, type)).toList();
context.start();
for (LeaderRecorder member : members) {
@@ -371,7 +371,7 @@ public class KubernetesClusterServiceTest extends
CamelTestSupport {
private void checkLeadershipChangeDistance(long minimum, TimeUnit unit,
LeaderRecorder... recorders) {
List<LeaderRecorder.LeadershipInfo> infos =
Arrays.stream(recorders).flatMap(lr -> lr.getLeadershipInfo().stream())
.sorted(Comparator.comparingLong(LeaderRecorder.LeadershipInfo::getChangeTimestamp))
- .collect(Collectors.toList());
+ .toList();
LeaderRecorder.LeadershipInfo currentLeaderLastSeen = null;
for (LeaderRecorder.LeadershipInfo info : infos) {
diff --git
a/components/camel-master/src/test/java/org/apache/camel/component/master/MasterComponentTest.java
b/components/camel-master/src/test/java/org/apache/camel/component/master/MasterComponentTest.java
index 8e02686efa0..0aa4e7b21a0 100644
---
a/components/camel-master/src/test/java/org/apache/camel/component/master/MasterComponentTest.java
+++
b/components/camel-master/src/test/java/org/apache/camel/component/master/MasterComponentTest.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -39,7 +38,7 @@ import static org.junit.jupiter.api.Assertions.assertTrue;
public class MasterComponentTest {
private static final Logger LOGGER =
LoggerFactory.getLogger(MasterComponentTest.class);
private static final List<String> INSTANCES
- = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ = IntStream.range(0, 3).mapToObj(Integer::toString).toList();
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(INSTANCES.size());
private static final CountDownLatch LATCH = new
CountDownLatch(INSTANCES.size());
diff --git
a/components/camel-nitrite/src/test/java/org/apache/camel/component/nitrite/AbstractNitriteTest.java
b/components/camel-nitrite/src/test/java/org/apache/camel/component/nitrite/AbstractNitriteTest.java
index dbc18cd30f9..9a39a574e14 100644
---
a/components/camel-nitrite/src/test/java/org/apache/camel/component/nitrite/AbstractNitriteTest.java
+++
b/components/camel-nitrite/src/test/java/org/apache/camel/component/nitrite/AbstractNitriteTest.java
@@ -19,7 +19,6 @@ package org.apache.camel.component.nitrite;
import java.io.File;
import java.lang.reflect.Method;
import java.util.List;
-import java.util.stream.Collectors;
import org.apache.camel.Exchange;
import org.apache.camel.test.junit5.CamelTestSupport;
@@ -55,7 +54,7 @@ public abstract class AbstractNitriteTest extends
CamelTestSupport implements Be
return 0;
}
return Long.compare(timestamp1, timestamp2);
- }).collect(Collectors.toList());
+ }).toList();
}
}
diff --git
a/components/camel-opentelemetry/src/test/java/org/apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java
b/components/camel-opentelemetry/src/test/java/org/apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java
index c4d49c9a60d..1fd59a4cb70 100644
---
a/components/camel-opentelemetry/src/test/java/org/apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java
+++
b/components/camel-opentelemetry/src/test/java/org/apache/camel/opentelemetry/CamelOpenTelemetryTestSupport.java
@@ -26,7 +26,6 @@ import java.util.Map;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import java.util.function.Function;
-import java.util.stream.Collectors;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.api.trace.Tracer;
@@ -120,7 +119,7 @@ class CamelOpenTelemetryTestSupport extends
CamelTestSupport {
if (async) {
final List<SpanData> unsortedSpans = spans;
spans = Arrays.stream(expected)
- .map(td -> findSpan(td,
unsortedSpans)).distinct().collect(Collectors.toList());
+ .map(td -> findSpan(td,
unsortedSpans)).distinct().toList();
assertEquals(expected.length, spans.size(), "Incorrect number of
spans after sorting");
}
diff --git
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarSuspendRouteIT.java
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarSuspendRouteIT.java
index 95ea4cef80d..f466e7bdde2 100644
---
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarSuspendRouteIT.java
+++
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/integration/PulsarSuspendRouteIT.java
@@ -21,7 +21,6 @@ import java.util.List;
import java.util.UUID;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import org.apache.camel.Endpoint;
import org.apache.camel.EndpointInject;
@@ -212,7 +211,7 @@ public class PulsarSuspendRouteIT extends PulsarITSupport {
List<MessageId> receivedMessageIds = to.getReceivedExchanges().stream()
.map(e -> e.getIn().getHeader(PulsarMessageHeaders.MESSAGE_ID,
MessageId.class))
- .collect(Collectors.toList());
+ .toList();
assertEquals(sentMessageIds, receivedMessageIds);
}
diff --git
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ConcurrentConsumersTest.java
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ConcurrentConsumersTest.java
index 6fb6a2da56b..424587e6ae6 100644
---
a/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ConcurrentConsumersTest.java
+++
b/components/camel-reactive-streams/src/test/java/org/apache/camel/component/reactive/streams/ConcurrentConsumersTest.java
@@ -55,7 +55,7 @@ public class ConcurrentConsumersTest extends BaseReactiveTest
{
// Ensure order is preserved when using a single consumer
List<Long> nums = endpoint.getExchanges().stream()
.map(x -> x.getIn().getBody(Long.class))
- .collect(Collectors.toList());
+ .toList();
long prev = -1;
for (long n : nums) {
diff --git
a/components/camel-spring-xml/src/test/java/org/apache/camel/spring/health/HealthCheckRegistryTest.java
b/components/camel-spring-xml/src/test/java/org/apache/camel/spring/health/HealthCheckRegistryTest.java
index 92e5f750eaa..9b4598197dd 100644
---
a/components/camel-spring-xml/src/test/java/org/apache/camel/spring/health/HealthCheckRegistryTest.java
+++
b/components/camel-spring-xml/src/test/java/org/apache/camel/spring/health/HealthCheckRegistryTest.java
@@ -17,7 +17,6 @@
package org.apache.camel.spring.health;
import java.util.List;
-import java.util.stream.Collectors;
import org.apache.camel.CamelContext;
import org.apache.camel.health.HealthCheck;
@@ -39,7 +38,7 @@ public class HealthCheckRegistryTest {
HealthCheckRegistry hc =
context.getCamelContextExtension().getContextPlugin(HealthCheckRegistry.class);
assertNotNull(hc);
- List<HealthCheck> checks = hc.stream().collect(Collectors.toList());
+ List<HealthCheck> checks = hc.stream().toList();
assertEquals(2, checks.size());
for (HealthCheck check : checks) {
diff --git
a/components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramChatBotTest.java
b/components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramChatBotTest.java
index 62497c810eb..f6a2f7fe7a8 100644
---
a/components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramChatBotTest.java
+++
b/components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramChatBotTest.java
@@ -47,7 +47,7 @@ public class TelegramChatBotTest extends TelegramTestSupport {
rawMessages -> rawMessages.size() >= 2)
.stream()
.map(message -> (OutgoingTextMessage) message)
- .collect(Collectors.toList());
+ .toList();
assertCollectionSize(msgs, 2);
assertTrue(msgs.stream().anyMatch(m -> "echo from the bot: Hello
World!".equals(m.getText())));
diff --git
a/components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramConsumerFallbackConversionTest.java
b/components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramConsumerFallbackConversionTest.java
index 1e054c35823..b49bebcfbbf 100644
---
a/components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramConsumerFallbackConversionTest.java
+++
b/components/camel-telegram/src/test/java/org/apache/camel/component/telegram/TelegramConsumerFallbackConversionTest.java
@@ -18,7 +18,6 @@ package org.apache.camel.component.telegram;
import java.util.List;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import org.apache.camel.EndpointInject;
import org.apache.camel.ProducerTemplate;
@@ -52,7 +51,7 @@ public class TelegramConsumerFallbackConversionTest extends
TelegramTestSupport
rawMessages -> rawMessages.size() == 1)
.stream()
.map(message -> (OutgoingTextMessage) message)
- .collect(Collectors.toList());
+ .toList();
assertCollectionSize(msgs, 1);
String text = msgs.get(0).getText();
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
index 06633ee0657..2cdb76ecfa1 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyFactoryIT.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -45,7 +44,7 @@ public final class ZooKeeperClusteredRoutePolicyFactoryIT {
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperClusteredRoutePolicyFactoryIT.class);
- private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).toList();
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size() * 2);
private static final CountDownLatch LATCH = new
CountDownLatch(CLIENTS.size());
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
index 9600dad1886..3ea4dd6395f 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperClusteredRoutePolicyIT.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -45,7 +44,7 @@ public final class ZooKeeperClusteredRoutePolicyIT {
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperClusteredRoutePolicyIT.class);
- private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).toList();
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size() * 2);
private static final CountDownLatch LATCH = new
CountDownLatch(CLIENTS.size());
diff --git
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
index 3bc75576e45..d1e23eafffe 100644
---
a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
+++
b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/cluster/integration/ZooKeeperMasterIT.java
@@ -23,7 +23,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ThreadLocalRandom;
import java.util.concurrent.TimeUnit;
-import java.util.stream.Collectors;
import java.util.stream.IntStream;
import org.apache.camel.builder.RouteBuilder;
@@ -44,7 +43,7 @@ public final class ZooKeeperMasterIT {
static ZooKeeperService service = ZooKeeperServiceFactory.createService();
private static final Logger LOGGER =
LoggerFactory.getLogger(ZooKeeperMasterIT.class);
- private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).collect(Collectors.toList());
+ private static final List<String> CLIENTS = IntStream.range(0,
3).mapToObj(Integer::toString).toList();
private static final List<String> RESULTS = new ArrayList<>();
private static final ScheduledExecutorService SCHEDULER =
Executors.newScheduledThreadPool(CLIENTS.size());
private static final CountDownLatch LATCH = new
CountDownLatch(CLIENTS.size());
