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 <[email protected]> Authored: Tue Sep 8 21:27:18 2015 -0400 Committer: reta <[email protected]> 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; }
