Repository: camel Updated Branches: refs/heads/master dfa458a2e -> fbe97105b
CAMEL-8526: Add more EIP as specialized mbeans Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/fbe97105 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/fbe97105 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/fbe97105 Branch: refs/heads/master Commit: fbe97105bb4e6e597fafd6dc80e7842206d74a05 Parents: dfa458a Author: Claus Ibsen <[email protected]> Authored: Wed Jul 22 08:11:41 2015 +0200 Committer: Claus Ibsen <[email protected]> Committed: Wed Jul 22 08:11:41 2015 +0200 ---------------------------------------------------------------------- .../camel/api/management/mbean/ManagedProcessorMBean.java | 3 +++ .../org/apache/camel/management/mbean/ManagedProcessor.java | 6 ++++++ .../org/apache/camel/management/ManagedSplitterTest.java | 9 +++++++-- 3 files changed, 16 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/fbe97105/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java index 3fe8fa5..bacb515 100644 --- a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java +++ b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedProcessorMBean.java @@ -53,4 +53,7 @@ public interface ManagedProcessorMBean extends ManagedPerformanceCounterMBean { @ManagedOperation(description = "Explain how this processor is configured") TabularData explain(boolean allOptions); + @ManagedOperation(description = "Dumps the processor as XML") + String dumpProcessorAsXml() throws Exception; + } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/camel/blob/fbe97105/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedProcessor.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedProcessor.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedProcessor.java index 39a7dc1..e1d9ef3 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedProcessor.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedProcessor.java @@ -34,6 +34,7 @@ import org.apache.camel.api.management.ManagedInstance; import org.apache.camel.api.management.ManagedResource; import org.apache.camel.api.management.mbean.CamelOpenMBeanTypes; import org.apache.camel.api.management.mbean.ManagedProcessorMBean; +import org.apache.camel.model.ModelHelper; import org.apache.camel.model.ProcessorDefinition; import org.apache.camel.util.JsonSchemaHelper; import org.apache.camel.util.ObjectHelper; @@ -171,4 +172,9 @@ public class ManagedProcessor extends ManagedPerformanceCounter implements Manag throw ObjectHelper.wrapRuntimeCamelException(e); } } + + @Override + public String dumpProcessorAsXml() throws Exception { + return ModelHelper.dumpModelAsXml(context, definition); + } } http://git-wip-us.apache.org/repos/asf/camel/blob/fbe97105/camel-core/src/test/java/org/apache/camel/management/ManagedSplitterTest.java ---------------------------------------------------------------------- diff --git a/camel-core/src/test/java/org/apache/camel/management/ManagedSplitterTest.java b/camel-core/src/test/java/org/apache/camel/management/ManagedSplitterTest.java index 1f90754..bafff6d 100644 --- a/camel-core/src/test/java/org/apache/camel/management/ManagedSplitterTest.java +++ b/camel-core/src/test/java/org/apache/camel/management/ManagedSplitterTest.java @@ -59,7 +59,12 @@ public class ManagedSplitterTest extends ManagementTestSupport { assertEquals(ServiceStatus.Started.name(), state); String uri = (String) mbeanServer.getAttribute(on, "Expression"); - assertEquals("tokenize(body, ,)", uri); + assertEquals("Simple: ${body}", uri); + + String xml = (String) mbeanServer.invoke(on, "dumpProcessorAsXml", null, null); + assertTrue(xml.contains("<split")); + assertTrue(xml.contains("</split>")); + assertTrue(xml.contains("<simple>${body}</simple>")); TabularData data = (TabularData) mbeanServer.invoke(on, "explain", new Object[]{false}, new String[]{"boolean"}); assertNotNull(data); @@ -80,7 +85,7 @@ public class ManagedSplitterTest extends ManagementTestSupport { @Override public void configure() throws Exception { from("direct:start") - .split(body().tokenize(",")).id("mysend") + .split(simple("${body}")).id("mysend") .to("mock:foo"); } };
