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;
}
|