cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r...@apache.org
Subject cxf git commit: CXF-6360: Integration with Apache HTrace. Finalizing HBase demo project.
Date Wed, 09 Sep 2015 01:27:30 GMT
Repository: cxf
Updated Branches:
  refs/heads/master 94a6c2439 -> e28d25804


CXF-6360: Integration with Apache HTrace. Finalizing HBase demo project.


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

Branch: refs/heads/master
Commit: e28d258049dc8501f6d2bc4d33ef21914d5a38bb
Parents: 94a6c24
Author: reta <drreta@gmail.com>
Authored: Tue Sep 8 21:27:18 2015 -0400
Committer: reta <drreta@gmail.com>
Committed: Tue Sep 8 21:27:18 2015 -0400

----------------------------------------------------------------------
 .../src/main/java/demo/jaxrs/tracing/server/Catalog.java         | 4 ++++
 .../src/main/java/demo/jaxrs/tracing/server/CatalogStore.java    | 4 ++++
 2 files changed, 8 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cxf/blob/e28d2580/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/Catalog.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/Catalog.java
b/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/Catalog.java
index 105c53e..11ac82b 100644
--- a/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/Catalog.java
+++ b/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/Catalog.java
@@ -47,6 +47,9 @@ import org.apache.cxf.tracing.Traceable;
 import org.apache.cxf.tracing.TracerContext;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.hbase.HBaseConfiguration;
+import org.apache.hadoop.hbase.trace.SpanReceiverHost;
+
+import demo.jaxrs.tracing.conf.TracingConfiguration;
 
 @Path("/catalog")
 public class Catalog {
@@ -57,6 +60,7 @@ public class Catalog {
         final Configuration configuration = HBaseConfiguration.create();
         configuration.set("hbase.zookeeper.quorum", "hbase");
         configuration.set("hbase.zookeeper.property.clientPort", "2181");
+        configuration.set(SpanReceiverHost.SPAN_RECEIVERS_CONF_KEY, TracingConfiguration.SPAN_RECEIVER.getName());
         store = new CatalogStore(configuration, "catalog");
     }
     

http://git-wip-us.apache.org/repos/asf/cxf/blob/e28d2580/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/CatalogStore.java
----------------------------------------------------------------------
diff --git a/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/CatalogStore.java
b/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/CatalogStore.java
index 6a37e13..060cbbb 100644
--- a/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/CatalogStore.java
+++ b/distribution/src/main/release/samples/jax_rs/tracing_htrace/src/main/java/demo/jaxrs/tracing/server/CatalogStore.java
@@ -39,14 +39,18 @@ import org.apache.hadoop.hbase.client.Result;
 import org.apache.hadoop.hbase.client.ResultScanner;
 import org.apache.hadoop.hbase.client.Scan;
 import org.apache.hadoop.hbase.client.Table;
+import org.apache.hadoop.hbase.trace.SpanReceiverHost;
 import org.apache.hadoop.hbase.util.Bytes;
 
 public class CatalogStore {
+    @SuppressWarnings("unused")
+    private final SpanReceiverHost spanReceiverHost;
     private final Connection connection;
     private final String tableName;
     
     public CatalogStore(final Configuration configuration, final String tableName) throws
IOException {
         this.connection = ConnectionFactory.createConnection(configuration);
+        this.spanReceiverHost = SpanReceiverHost.getInstance(configuration);
         this.tableName = tableName;
     }
     


Mime
View raw message