camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [2/2] camel git commit: CAMEL-6858: Delayer EIP - Add JMX attribute to know if any messages are delayed
Date Sat, 11 Jul 2015 06:30:48 GMT
CAMEL-6858: Delayer EIP - Add JMX attribute to know if any messages are delayed


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/84706599
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/84706599
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/84706599

Branch: refs/heads/master
Commit: 847065993f349d6a035552fc0d69941b8a45599f
Parents: 2ffd352
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Sat Jul 11 08:37:17 2015 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Sat Jul 11 08:37:17 2015 +0200

----------------------------------------------------------------------
 .../apache/camel/api/management/mbean/ManagedDelayerMBean.java    | 3 +++
 .../java/org/apache/camel/management/mbean/ManagedDelayer.java    | 3 +++
 2 files changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/84706599/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java
b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java
index 1cc0061..5f28641 100644
--- a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java
+++ b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedDelayerMBean.java
@@ -27,4 +27,7 @@ public interface ManagedDelayerMBean extends ManagedProcessorMBean {
     @ManagedOperation(description = "Set a constant delay in millis")
     void constantDelay(Integer millis);
 
+    @ManagedAttribute(description = "Number of exchanges currently delayed")
+    int getDelayedCount();
+
 }
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/camel/blob/84706599/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDelayer.java
----------------------------------------------------------------------
diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDelayer.java
b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDelayer.java
index 5f77399..ce2a45e 100644
--- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDelayer.java
+++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedDelayer.java
@@ -49,4 +49,7 @@ public class ManagedDelayer extends ManagedProcessor implements ManagedDelayerMB
         getDelayer().setDelay(delay);
     }
 
+    public int getDelayedCount() {
+        return getDelayer().getDelayedCount();
+    }
 }


Mime
View raw message