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/07/20 22:47:26 UTC
[5/7] camel git commit: CAMEL-8965: WireTap supports dynamic uris
like toD does
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 <da...@apache.org>
Authored: Mon Jul 20 21:57:03 2015 +0200
Committer: Claus Ibsen <da...@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);