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 2018/09/05 08:38:55 UTC
[camel] 02/02: CAMEL-12775: Fixed stub component with MEP InOut vs
InOnly mode would expect a reply message or not. Otherwise InOut with no
active consumer would block and timeout after 30 seconds and fail. Thanks
to Guido Schreuder for reporting and the unit test.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-2.21.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 10270f8aa2a9b04ce9a10f53f03f08045b9cd829
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Sep 5 10:37:36 2018 +0200
CAMEL-12775: Fixed stub component with MEP InOut vs InOnly mode would expect a reply message or not. Otherwise InOut with no active consumer would block and timeout after 30 seconds and fail. Thanks to Guido Schreuder for reporting and the unit test.
---
.../src/main/java/org/apache/camel/component/stub/StubEndpoint.java | 2 +-
.../src/main/java/org/apache/camel/component/stub/StubProducer.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/camel-core/src/main/java/org/apache/camel/component/stub/StubEndpoint.java b/camel-core/src/main/java/org/apache/camel/component/stub/StubEndpoint.java
index 25b0e67..2d71e17 100644
--- a/camel-core/src/main/java/org/apache/camel/component/stub/StubEndpoint.java
+++ b/camel-core/src/main/java/org/apache/camel/component/stub/StubEndpoint.java
@@ -61,6 +61,6 @@ public class StubEndpoint extends VmEndpoint {
@Override
public Producer createProducer() throws Exception {
- return new StubProducer(this, getWaitForTaskToComplete(), getTimeout(), isBlockWhenFull(), getOfferTimeout());
+ return new StubProducer(this, getWaitForTaskToComplete(), getTimeout(), isBlockWhenFull());
}
}
diff --git a/camel-core/src/main/java/org/apache/camel/component/stub/StubProducer.java b/camel-core/src/main/java/org/apache/camel/component/stub/StubProducer.java
index 582aeb8..e1cf135 100644
--- a/camel-core/src/main/java/org/apache/camel/component/stub/StubProducer.java
+++ b/camel-core/src/main/java/org/apache/camel/component/stub/StubProducer.java
@@ -26,8 +26,8 @@ import org.apache.camel.component.seda.SedaProducer;
public class StubProducer extends SedaProducer {
- public StubProducer(SedaEndpoint endpoint, WaitForTaskToComplete waitForTaskToComplete, long timeout, boolean blockWhenFull, long offerTimeout) {
- super(endpoint, waitForTaskToComplete, timeout, blockWhenFull, offerTimeout);
+ public StubProducer(SedaEndpoint endpoint, WaitForTaskToComplete waitForTaskToComplete, long timeout, boolean blockWhenFull) {
+ super(endpoint, waitForTaskToComplete, timeout, blockWhenFull);
}
@Override