You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2018/04/18 15:18:58 UTC
[camel] branch master updated: CAMEL-11669: Add route group to JMX
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 78c9735 CAMEL-11669: Add route group to JMX
78c9735 is described below
commit 78c9735d293aae75ac89054834894db6f2ba873d
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed Apr 18 17:18:48 2018 +0200
CAMEL-11669: Add route group to JMX
---
.../apache/camel/api/management/mbean/ManagedRouteMBean.java | 3 +++
.../java/org/apache/camel/management/mbean/ManagedRoute.java | 4 ++++
.../apache/camel/management/ManagedRegisterRouteTest.java | 12 +++++++++++-
3 files changed, 18 insertions(+), 1 deletion(-)
diff --git a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java
index 51103e7..d8d197e 100644
--- a/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java
+++ b/camel-core/src/main/java/org/apache/camel/api/management/mbean/ManagedRouteMBean.java
@@ -26,6 +26,9 @@ public interface ManagedRouteMBean extends ManagedPerformanceCounterMBean {
@ManagedAttribute(description = "Route ID")
String getRouteId();
+ @ManagedAttribute(description = "Route Group")
+ String getRouteGroup();
+
@ManagedAttribute(description = "Route Description")
String getDescription();
diff --git a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java
index 7c74a45..0d83c63 100644
--- a/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java
+++ b/camel-core/src/main/java/org/apache/camel/management/mbean/ManagedRoute.java
@@ -99,6 +99,10 @@ public class ManagedRoute extends ManagedPerformanceCounter implements TimerList
return id;
}
+ public String getRouteGroup() {
+ return route.getGroup();
+ }
+
public String getDescription() {
return description;
}
diff --git a/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java b/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java
index 946430c..5426267 100644
--- a/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java
+++ b/camel-core/src/test/java/org/apache/camel/management/ManagedRegisterRouteTest.java
@@ -48,6 +48,15 @@ public class ManagedRegisterRouteTest extends ManagementTestSupport {
// the route has this starting endpoint uri
assertEquals("direct://start", uri);
+ String id = (String) mbeanServer.getAttribute(on, "RouteId");
+ assertEquals("myRoute", id);
+
+ String group = (String) mbeanServer.getAttribute(on, "RouteGroup");
+ assertEquals("myGroup", group);
+
+ String desc = (String) mbeanServer.getAttribute(on, "Description");
+ assertEquals("my cool route", desc);
+
Integer val = (Integer) mbeanServer.getAttribute(on, "InflightExchanges");
// the route has no inflight exchanges
assertEquals(0, val.intValue());
@@ -72,7 +81,8 @@ public class ManagedRegisterRouteTest extends ManagementTestSupport {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:start").to("log:foo").to("mock:result");
+ from("direct:start").routeId("myRoute").routeGroup("myGroup").description("my cool route")
+ .to("log:foo").to("mock:result");
}
};
}
--
To stop receiving notification emails like this one, please contact
davsclaus@apache.org.