CAMEL-8965: WireTap supports dynamic uris like toD does
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/01dead92 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/01dead92 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/01dead92 Branch: refs/heads/master Commit: 01dead92e3c8a5eea84318bdef5081b0d143f107 Parents: 42effa4 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Jul 20 22:53:52 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Jul 20 22:54:09 2015 +0200 ---------------------------------------------------------------------- .../src/main/java/org/apache/camel/model/WireTapDefinition.java | 3 +++ 1 file changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/01dead92/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java b/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java index 4cf47a1..22a1e22 100644 --- a/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java +++ b/camel-core/src/main/java/org/apache/camel/model/WireTapDefinition.java @@ -73,6 +73,9 @@ public class WireTapDefinition<Type extends ProcessorDefinition<Type>> extends T boolean shutdownThreadPool = ProcessorDefinitionHelper.willCreateNewThreadPool(routeContext, this, true); ExecutorService threadPool = ProcessorDefinitionHelper.getConfiguredExecutorService(routeContext, "WireTap", this, true); + // must use InOnly for WireTap + setPattern(ExchangePattern.InOnly); + // create the send dynamic producer to send to the wire tapped endpoint SendDynamicProcessor dynamicTo = (SendDynamicProcessor) super.createProcessor(routeContext);
