camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [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.
Date Wed, 05 Sep 2018 08:38:55 GMT
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.ibsen@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


Mime
View raw message