[camel] branch master updated: CAMEL-11669: Add route group to JMX

[davsclaus]

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 <claus.ib...@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
davscl...@apache.org.