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 2022/06/20 12:19:15 UTC
[camel] 02/09: (chores) camel-directvm: removed unused parameters
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 fc2709f06ae10c7a509402aa4ea61965ef71f4f2
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Jun 20 10:44:58 2022 +0200
(chores) camel-directvm: removed unused parameters
---
.../java/org/apache/camel/component/directvm/DirectVmComponent.java | 2 +-
.../java/org/apache/camel/component/directvm/DirectVmConsumer.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/components/camel-directvm/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java b/components/camel-directvm/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java
index bc1c4dd70fd..a5a4e33d0d4 100644
--- a/components/camel-directvm/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java
+++ b/components/camel-directvm/src/main/java/org/apache/camel/component/directvm/DirectVmComponent.java
@@ -93,7 +93,7 @@ public class DirectVmComponent extends DefaultComponent {
}
}
- public void removeConsumer(DirectVmEndpoint endpoint, DirectVmConsumer consumer) {
+ public void removeConsumer(DirectVmEndpoint endpoint) {
String key = getConsumerKey(endpoint.getEndpointUri());
CONSUMERS.remove(key);
}
diff --git a/components/camel-directvm/src/main/java/org/apache/camel/component/directvm/DirectVmConsumer.java b/components/camel-directvm/src/main/java/org/apache/camel/component/directvm/DirectVmConsumer.java
index 01d11d483ef..897e8ae308f 100644
--- a/components/camel-directvm/src/main/java/org/apache/camel/component/directvm/DirectVmConsumer.java
+++ b/components/camel-directvm/src/main/java/org/apache/camel/component/directvm/DirectVmConsumer.java
@@ -42,13 +42,13 @@ public class DirectVmConsumer extends DefaultConsumer implements Suspendable {
@Override
protected void doStop() throws Exception {
- getEndpoint().getComponent().removeConsumer(getEndpoint(), this);
+ getEndpoint().getComponent().removeConsumer(getEndpoint());
super.doStop();
}
@Override
protected void doSuspend() throws Exception {
- getEndpoint().getComponent().removeConsumer(getEndpoint(), this);
+ getEndpoint().getComponent().removeConsumer(getEndpoint());
}
@Override