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
The following commit(s) were added to refs/heads/master by this push: new cc13302 camel-direct: Remove unused producer list in DirectEndpoint and delete related methods. (#3433) cc13302 is described below commit cc133027272a00e54ba3f0659567cb1ce0a6d479 Author: Pascal Schumacher <pascalschumac...@gmx.net> AuthorDate: Sat Dec 21 08:25:27 2019 +0100 camel-direct: Remove unused producer list in DirectEndpoint and delete related methods. (#3433) --- .../org/apache/camel/component/direct/DirectEndpoint.java | 15 --------------- .../org/apache/camel/component/direct/DirectProducer.java | 12 ------------ 2 files changed, 27 deletions(-) diff --git a/components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java b/components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java index 9b2cfd0..bc9043c 100644 --- a/components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java +++ b/components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectEndpoint.java @@ -16,9 +16,7 @@ */ package org.apache.camel.component.direct; -import java.util.ArrayList; import java.util.HashMap; -import java.util.List; import java.util.Map; import org.apache.camel.Component; @@ -42,7 +40,6 @@ import org.apache.camel.util.StringHelper; public class DirectEndpoint extends DefaultEndpoint { private final Map<String, DirectConsumer> consumers; - private final List<DirectProducer> producers = new ArrayList<>(); @UriPath(description = "Name of direct endpoint") @Metadata(required = true) private String name; @@ -97,18 +94,6 @@ public class DirectEndpoint extends DefaultEndpoint { } } - public void addProducer(DirectProducer producer) { - synchronized (consumers) { - producers.add(producer); - } - } - - public void removeProducer(DirectProducer producer) { - synchronized (consumers) { - producers.remove(producer); - } - } - protected DirectConsumer getConsumer() throws InterruptedException { String key = getKey(); synchronized (consumers) { diff --git a/components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectProducer.java b/components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectProducer.java index 0982568..68f6775 100644 --- a/components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectProducer.java +++ b/components/camel-direct/src/main/java/org/apache/camel/component/direct/DirectProducer.java @@ -33,18 +33,6 @@ public class DirectProducer extends DefaultAsyncProducer { } @Override - protected void doStart() throws Exception { - super.doStart(); - endpoint.addProducer(this); - } - - @Override - protected void doStop() throws Exception { - endpoint.removeProducer(this); - super.doStop(); - } - - @Override public void process(Exchange exchange) throws Exception { DirectConsumer consumer = endpoint.getConsumer(); if (consumer == null) {