[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.

[davsclaus]

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 <claus.ib...@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