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 2015/06/04 11:08:23 UTC
[3/3] camel git commit: CAMEL-8829: Do a defensive copy of the
message when creating correlated copy,
to eavoid any ConcurrentModificationException such as routing to logs using
concurrent threads or if using wire tap EIP etc.
CAMEL-8829: Do a defensive copy of the message when creating correlated copy, to eavoid any ConcurrentModificationException such as routing to logs using concurrent threads or if using wire tap EIP etc.
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/f6aa990c
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/f6aa990c
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/f6aa990c
Branch: refs/heads/master
Commit: f6aa990c00cfbe8a70bd36cbad69f7268f891fde
Parents: 6d6d1b7
Author: Claus Ibsen <da...@apache.org>
Authored: Thu Jun 4 11:11:45 2015 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Thu Jun 4 11:11:45 2015 +0200
----------------------------------------------------------------------
.../src/main/scala/org/apache/camel/scala/RichExchange.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/f6aa990c/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala
----------------------------------------------------------------------
diff --git a/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala b/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala
index 3cb9262..e908e39 100644
--- a/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala
+++ b/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala
@@ -127,6 +127,8 @@ class RichExchange(val exchange : Exchange) extends Exchange {
def copy = new RichExchange(exchange.copy)
+ def copy(safeCopy: Boolean) = new RichExchange(exchange.copy(safeCopy))
+
def addOnCompletion(onCompletion: Synchronization) { exchange.addOnCompletion(onCompletion) }
def containsOnCompletion(onCompletion: Synchronization) = exchange.containsOnCompletion(onCompletion)