You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2014/12/17 08:10:02 UTC
camel git commit: CAMEL-8154 Added JMX operation as Claus suggested
Repository: camel
Updated Branches:
refs/heads/master 8a5a0cb73 -> 0866d136d
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/0866d136
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0866d136
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0866d136
Branch: refs/heads/master
Commit: 0866d136dbb416e8e5f9a6c0ce7de8bb8d3a4dea
Parents: 8a5a0cb
Author: Willem Jiang <wi...@gmail.com>
Authored: Wed Dec 17 15:09:29 2014 +0800
Committer: Willem Jiang <wi...@gmail.com>
Committed: Wed Dec 17 15:09:43 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/0866d136/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/0866d136/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);
+ }
}