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 86cbf9586c929fa44f8d027ab67e93ba996758fa Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Fri May 19 14:49:47 2023 +0200 (chores) camel-azure-storage-queue: use unmodifiable list when possible --- .../component/azure/storage/queue/client/QueueClientWrapper.java | 5 ++--- .../azure/storage/queue/client/QueueServiceClientWrapper.java | 3 +-- 2 files changed, 3 insertions(+), 5 deletions(-) diff --git a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueClientWrapper.java b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueClientWrapper.java index 61b31cbdbce..76aa15f4a5d 100644 --- a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueClientWrapper.java +++ b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueClientWrapper.java @@ -19,7 +19,6 @@ package org.apache.camel.component.azure.storage.queue.client; import java.time.Duration; import java.util.List; import java.util.Map; -import java.util.stream.Collectors; import com.azure.core.http.rest.Response; import com.azure.core.util.Context; @@ -63,11 +62,11 @@ public class QueueClientWrapper { public List<QueueMessageItem> receiveMessages(Integer maxMessages, Duration visibilityTimeout, Duration timeout) { return client.receiveMessages(maxMessages, visibilityTimeout, timeout, Context.NONE).stream() - .collect(Collectors.toList()); + .toList(); } public List<PeekedMessageItem> peekMessages(Integer maxMessages, Duration timeout) { - return client.peekMessages(maxMessages, timeout, Context.NONE).stream().collect(Collectors.toList()); + return client.peekMessages(maxMessages, timeout, Context.NONE).stream().toList(); } public Response<UpdateMessageResult> updateMessage( diff --git a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueServiceClientWrapper.java b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueServiceClientWrapper.java index 5760adabc87..4dfb3a21f3a 100644 --- a/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueServiceClientWrapper.java +++ b/components/camel-azure/camel-azure-storage-queue/src/main/java/org/apache/camel/component/azure/storage/queue/client/QueueServiceClientWrapper.java @@ -18,7 +18,6 @@ package org.apache.camel.component.azure.storage.queue.client; import java.time.Duration; import java.util.List; -import java.util.stream.Collectors; import com.azure.core.util.Context; import com.azure.storage.queue.QueueServiceClient; @@ -37,7 +36,7 @@ public class QueueServiceClientWrapper { } public List<QueueItem> listQueues(QueuesSegmentOptions options, Duration timeout) { - return client.listQueues(options, timeout, Context.NONE).stream().collect(Collectors.toList()); + return client.listQueues(options, timeout, Context.NONE).stream().toList(); } public QueueClientWrapper getQueueClientWrapper(final String queueName) {
