This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 11728ab7a71a982f589118e4e1382f16ebf02f76 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Wed Feb 19 10:14:40 2020 +0100 Remove not needed code --- .../main/java/org/apache/camel/processor/RecipientList.java | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/core/camel-base/src/main/java/org/apache/camel/processor/RecipientList.java b/core/camel-base/src/main/java/org/apache/camel/processor/RecipientList.java index 05f924b..e913ffd 100644 --- a/core/camel-base/src/main/java/org/apache/camel/processor/RecipientList.java +++ b/core/camel-base/src/main/java/org/apache/camel/processor/RecipientList.java @@ -23,7 +23,6 @@ import java.util.concurrent.ExecutorService; import org.apache.camel.AggregationStrategy; import org.apache.camel.AsyncCallback; import org.apache.camel.CamelContext; -import org.apache.camel.Endpoint; import org.apache.camel.Exchange; import org.apache.camel.Expression; import org.apache.camel.Processor; @@ -35,7 +34,6 @@ import org.apache.camel.spi.IdAware; import org.apache.camel.spi.ProducerCache; import org.apache.camel.spi.RouteIdAware; import org.apache.camel.support.AsyncProcessorSupport; -import org.apache.camel.support.ExchangeHelper; import org.apache.camel.support.ObjectHelper; import org.apache.camel.support.service.ServiceHelper; import org.apache.camel.util.StringHelper; @@ -219,14 +217,6 @@ public class RecipientList extends AsyncProcessorSupport implements IdAware, Rou return rlp.process(exchange, callback); } - protected Endpoint resolveEndpoint(Exchange exchange, Object recipient) { - // trim strings as end users might have added spaces between separators - if (recipient instanceof String) { - recipient = ((String)recipient).trim(); - } - return ExchangeHelper.resolveEndpoint(exchange, recipient); - } - public EndpointUtilizationStatistics getEndpointUtilizationStatistics() { return producerCache.getEndpointUtilizationStatistics(); }