cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dk...@apache.org
Subject [4/6] cxf git commit: Setup JMX for the throttling server so you can "watch" what is happening with JConsole
Date Tue, 07 Apr 2015 20:47:19 GMT
Setup JMX for the throttling server so you can "watch" what is happening with JConsole


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

Branch: refs/heads/master
Commit: 72ba5f34d674012e2f8ca8ef5add0b022235ee06
Parents: b248d09
Author: Daniel Kulp <dkulp@apache.org>
Authored: Tue Apr 7 15:03:53 2015 -0400
Committer: Daniel Kulp <dkulp@apache.org>
Committed: Tue Apr 7 16:30:26 2015 -0400

----------------------------------------------------------------------
 .../src/main/java/demo/throttling/server/Customer.java      | 2 +-
 .../src/main/java/demo/throttling/server/Server.java        | 9 +++++++--
 2 files changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cxf/blob/72ba5f34/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Customer.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Customer.java
b/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Customer.java
index 012463f..8436ded 100644
--- a/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Customer.java
+++ b/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Customer.java
@@ -38,7 +38,7 @@ public abstract class Customer {
     
     MetricsContext getMetricsContext(MetricRegistry registry) {
         if (metrics == null) {
-            metrics = new CodahaleMetricsContext("Customer-" + name, registry);
+            metrics = new CodahaleMetricsContext("demo.server:customer=" + name +",type=Customer,",
registry);
         }
         return metrics;
     }

http://git-wip-us.apache.org/repos/asf/cxf/blob/72ba5f34/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Server.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Server.java
b/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Server.java
index 05b726c..aa722cf 100644
--- a/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Server.java
+++ b/distribution/src/main/release/samples/throttling/src/main/java/demo/throttling/server/Server.java
@@ -29,9 +29,10 @@ import javax.xml.ws.Endpoint;
 import com.codahale.metrics.MetricRegistry;
 
 import org.apache.cxf.Bus;
-import org.apache.cxf.BusFactory;
+import org.apache.cxf.bus.CXFBusFactory;
 import org.apache.cxf.message.Message;
 import org.apache.cxf.metrics.MetricsFeature;
+import org.apache.cxf.metrics.codahale.CodahaleMetricsProvider;
 import org.apache.cxf.phase.Phase;
 import org.apache.cxf.throttling.ThrottleResponse;
 import org.apache.cxf.throttling.ThrottlingFeature;
@@ -49,8 +50,12 @@ public class Server {
         customers.put("Malcolm", new Customer.CheapCustomer("Malcolm"));
         customers.put("Jonas", new Customer.TrialCustomer("Jonas"));
         
-        Bus b = BusFactory.getDefaultBus();
+        Map<String, Object> properties = new HashMap<>();
+        properties.put("bus.jmx.usePlatformMBeanServer", Boolean.TRUE);
+        properties.put("bus.jmx.enabled", Boolean.TRUE);
+        Bus b = new CXFBusFactory().createBus(null, properties);
         MetricRegistry registry = new MetricRegistry();
+        CodahaleMetricsProvider.setupJMXReporter(b, registry);
         b.setExtension(registry, MetricRegistry.class);        
         
         ThrottlingManager manager = new ThrottlingManager() {


Mime
View raw message