Added optional namespace resolution for aws related services such as …

…DynamoDB or SQS
openzipkin · Nov 6, 2017 · 144e823 · 144e823
1 parent 50b5334
commit 144e823
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/storage-xray-udp/src/main/java/zipkin2/storage/xray_udp/UDPMessageEncoder.java b/storage-xray-udp/src/main/java/zipkin2/storage/xray_udp/UDPMessageEncoder.java
@@ -54,7 +54,10 @@ static byte[] doEncode(Span span) throws IOException {
     if (span.kind() == null
         || span.kind() != Span.Kind.SERVER && span.kind() != Span.Kind.CONSUMER) {
       writer.name("type").value("subsegment");
-      if (span.kind() != null) writer.name("namespace").value("remote");
+      if (span.kind() != null) {
+        String remote = span.tags().get("remote");
+        writer.name("namespace").value(remote == null ? "remote" : remote);
+      }
       writer.name("name").value(span.remoteServiceName() == null ? "" : span.remoteServiceName());
     }else{
       writer.name("name").value(span.localServiceName());