Rebased

Signed-off-by: Annanay <annanay.a@media.net>
jaegertracing · Mar 4, 2019 · 9d9aeb5 · 9d9aeb5
1 parent 15d2b20
commit 9d9aeb5
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cmd/agent/app/builder.go b/cmd/agent/app/builder.go
@@ -229,14 +229,14 @@ func CreateCollectorProxy(
 		len(tchanRep.CollectorHostPorts) > 0 &&
 		len(grpcRepOpts.CollectorHostPort) == 0 {
 		logger.Warn("Using deprecated configuration", zap.String("option", "--collector-host.port"))
-		return tchannel.NewCollectorProxy(tchanRep, mFactory, logger)
+		return tchannel.NewCollectorProxy(tchanRep, opts.AgentTags, mFactory, logger)
 	}
 	switch opts.ReporterType {
 	case reporter.GRPC:
 		grpclog.SetLoggerV2(grpclog.NewLoggerV2(ioutil.Discard, os.Stderr, os.Stderr))
-		return grpc.NewCollectorProxy(grpcRepOpts, mFactory, logger)
+		return grpc.NewCollectorProxy(grpcRepOpts, opts.AgentTags, mFactory, logger)
 	case reporter.TCHANNEL:
-		return tchannel.NewCollectorProxy(tchanRep, mFactory, logger)
+		return tchannel.NewCollectorProxy(tchanRep, opts.AgentTags, mFactory, logger)
 	default:
 		return nil, errors.New(fmt.Sprintf("unknown reporter type %s", string(opts.ReporterType)))
 	}