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 c0a9808  CAMEL-12108 - PR on behalf of Bas Claessen
c0a9808 is described below

commit c0a9808442eeada56457721c6244658e21b77fe7
Author: onders86 <ondersez...@gmail.com>
AuthorDate: Tue Jan 2 18:20:04 2018 +0300

    CAMEL-12108 - PR on behalf of Bas Claessen
---
 .../src/main/java/org/apache/camel/processor/WireTapProcessor.java     | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java 
b/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
index b95800a..5015d18 100644
--- a/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
+++ b/camel-core/src/main/java/org/apache/camel/processor/WireTapProcessor.java
@@ -227,6 +227,9 @@ public class WireTapProcessor extends ServiceSupport 
implements AsyncProcessor,
         Exchange copy = ExchangeHelper.createCorrelatedCopy(exchange, false);
         // set MEP to InOnly as this wire tap is a fire and forget
         copy.setPattern(ExchangePattern.InOnly);
+        // remove STREAM_CACHE_UNIT_OF_WORK property because this wire tap will
+        // close its own created stream cache(s)
+        copy.removeProperty(Exchange.STREAM_CACHE_UNIT_OF_WORK);
         return copy;
     }
 

-- 
To stop receiving notification emails like this one, please contact
['"commits@camel.apache.org" <commits@camel.apache.org>'].

Reply via email to