You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2019/12/21 07:25:40 UTC
[camel] branch master updated: camel-direct: Remove unused producer
list in DirectEndpoint and delete related methods. (#3433)
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 <pa...@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) {