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:53:36 UTC
[camel] 08/11: (chores) camel-core-processor: 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 5fbee10baf3b7a8008cade17e09d2f409bc28d90
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Fri May 19 15:11:41 2023 +0200
(chores) camel-core-processor: use unmodifiable list when possible
---
.../src/main/java/org/apache/camel/processor/Pipeline.java | 3 +--
.../apache/camel/processor/loadbalancer/WeightedLoadBalancer.java | 7 ++-----
2 files changed, 3 insertions(+), 7 deletions(-)
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java
index a002023cc4d..9f20c5b950e 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/Pipeline.java
@@ -19,7 +19,6 @@ package org.apache.camel.processor;
import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
-import java.util.stream.Collectors;
import org.apache.camel.AsyncCallback;
import org.apache.camel.AsyncProcessor;
@@ -122,7 +121,7 @@ public class Pipeline extends AsyncProcessorSupport implements Navigate<Processo
public Pipeline(CamelContext camelContext, Collection<Processor> processors) {
this.camelContext = camelContext;
this.reactiveExecutor = camelContext.getCamelContextExtension().getReactiveExecutor();
- this.processors = processors.stream().map(AsyncProcessorConverterHelper::convert).collect(Collectors.toList());
+ this.processors = processors.stream().map(AsyncProcessorConverterHelper::convert).toList();
this.size = processors.size();
}
diff --git a/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/WeightedLoadBalancer.java b/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/WeightedLoadBalancer.java
index a4b2e4073c5..84037f146a7 100644
--- a/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/WeightedLoadBalancer.java
+++ b/core/camel-core-processor/src/main/java/org/apache/camel/processor/loadbalancer/WeightedLoadBalancer.java
@@ -16,9 +16,7 @@
*/
package org.apache.camel.processor.loadbalancer;
-import java.util.Collections;
import java.util.List;
-import java.util.stream.Collectors;
public abstract class WeightedLoadBalancer extends QueueLoadBalancer {
protected final List<DistributionRatio> ratios;
@@ -28,10 +26,9 @@ public abstract class WeightedLoadBalancer extends QueueLoadBalancer {
transient int lastIndex = -1;
public WeightedLoadBalancer(List<Integer> distributionRatios) {
- List<DistributionRatio> ratios = distributionRatios.stream()
+ this.ratios = distributionRatios.stream()
.map(DistributionRatio::new)
- .collect(Collectors.toList());
- this.ratios = Collections.unmodifiableList(ratios);
+ .toList();
this.distributionRatioSum = ratios.stream()
.mapToInt(DistributionRatio::getDistributionWeight).sum();
this.runtimeRatioSum = distributionRatioSum;