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/8ba9da1b Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/8ba9da1b Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/8ba9da1b Branch: refs/heads/master Commit: 8ba9da1b752b7eb43603e9b506599c4f4e7ad9fd Parents: cc55671 Author: Claus Ibsen <davscl...@apache.org> Authored: Mon Jul 20 21:57:03 2015 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon Jul 20 22:54:09 2015 +0200 ---------------------------------------------------------------------- .../main/java/org/apache/camel/model/ToDynamicDefinition.java | 1 + .../java/org/apache/camel/management/ManagedWireTapTest.java | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/8ba9da1b/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java b/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java index 7f5483b..ef6e90d 100644 --- a/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java +++ b/camel-core/src/main/java/org/apache/camel/model/ToDynamicDefinition.java @@ -70,6 +70,7 @@ public class ToDynamicDefinition extends NoOutputDefinition<ToDynamicDefinition> Expression exp = createExpression(routeContext); SendDynamicProcessor processor = new SendDynamicProcessor(uri, exp); + processor.setCamelContext(routeContext.getCamelContext()); processor.setPattern(pattern); if (cacheSize != null) { processor.setCacheSize(cacheSize); http://git-wip-us.apache.org/repos/asf/camel/blob/8ba9da1b/camel-core/src/test/java/org/apache/camel/management/ManagedWireTapTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/management/ManagedWireTapTest.java b/camel-core/src/test/java/org/apache/camel/management/ManagedWireTapTest.java index 4638037..0946a99 100644 --- a/camel-core/src/test/java/org/apache/camel/management/ManagedWireTapTest.java +++ b/camel-core/src/test/java/org/apache/camel/management/ManagedWireTapTest.java @@ -63,11 +63,11 @@ public class ManagedWireTapTest extends ManagementTestSupport { TabularData data = (TabularData) mbeanServer.invoke(on, "explain", new Object[]{false}, new String[]{"boolean"}); assertNotNull(data); - assertEquals(2, data.size()); + assertEquals(3, data.size()); data = (TabularData) mbeanServer.invoke(on, "explain", new Object[]{true}, new String[]{"boolean"}); assertNotNull(data); - assertEquals(10, data.size()); + assertEquals(11, data.size()); String json = (String) mbeanServer.invoke(on, "informationJson", null, null); assertNotNull(json);
