Repository: camel Updated Branches: refs/heads/camel-2.13.x 9e7535ccc -> 3f81b292e refs/heads/camel-2.14.x 888c104eb -> 3fbaa01ea
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/3fbaa01e Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3fbaa01e Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3fbaa01e Branch: refs/heads/camel-2.14.x Commit: 3fbaa01ea19030757f664a8d28d721a0720e6512 Parents: 888c104 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:28 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/3fbaa01e/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 1281e35..47edfcd 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 @@ -106,7 +106,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/3fbaa01e/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 9baf5fb..a351610 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 @@ -218,4 +218,12 @@ public class ManagedBacklogDebugger implements ManagedBacklogDebuggerMBean { } } } + + public long getFallbackTimeout() { + return backlogDebugger.getFallbackTimeout(); + } + + public void setFallbackTimeout(long fallbackTimeout) { + backlogDebugger.setFallbackTimeout(fallbackTimeout); + } }
