CAMEL-8154 Added JMX operation as Claus suggested
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3f81b292 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3f81b292 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3f81b292 Branch: refs/heads/camel-2.13.x Commit: 3f81b292edcc90482297e1dbdcd511963a6390b2 Parents: 9e7535c Author: Willem Jiang <[email protected]> Authored: Wed Dec 17 15:09:29 2014 +0800 Committer: Willem Jiang <[email protected]> Committed: Wed Dec 17 15:10:40 2014 +0800 ---------------------------------------------------------------------- .../api/management/mbean/ManagedBacklogDebuggerMBean.java | 8 +++++++- .../camel/management/mbean/ManagedBacklogDebugger.java | 8 ++++++++ 2 files changed, 15 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3f81b292/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBacklogDebuggerMBean.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBacklogDebuggerMBean.java b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBacklogDebuggerMBean.java index a6a65e2..9fa30d6 100644 --- a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBacklogDebuggerMBean.java +++ b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedBacklogDebuggerMBean.java @@ -100,7 +100,13 @@ public interface ManagedBacklogDebuggerMBean { @ManagedAttribute(description = "Number of maximum chars in the message body in the trace message. Use zero or negative value to have unlimited size.") void setBodyMaxChars(int bodyMaxChars); - + + @ManagedAttribute(description = "Fallback Timeout in seconds when block the message processing in Camel.") + long getFallbackTimeout(); + + @ManagedAttribute(description = "Fallback Timeout in seconds when block the message processing in Camel.") + void setFallbackTimeout(long fallbackTimeout); + @ManagedAttribute(description = "Whether to include stream based message body in the trace message.") boolean isBodyIncludeStreams(); http://git-wip-us.apache.org/repos/asf/camel/blob/3f81b292/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java index ca00715..e1c6a3b 100644 --- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java +++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedBacklogDebugger.java @@ -211,4 +211,12 @@ public class ManagedBacklogDebugger implements ManagedBacklogDebuggerMBean { } } } + + public long getFallbackTimeout() { + return backlogDebugger.getFallbackTimeout(); + } + + public void setFallbackTimeout(long fallbackTimeout) { + backlogDebugger.setFallbackTimeout(fallbackTimeout); + } }
