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 2023/05/19 14:56:24 UTC
[camel] 06/06: (chores) camel-azure-storage-queue: use unmodifiable list when possible
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 <an...@gmail.com>
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) {