gaspersic/robot-shop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Leverage support for 'messaging_bus.address' in dispatch component

Browse Source
This commit is contained in:
Michele Mancioppi
2019-09-08 15:13:41 +02:00
parent 632d2a85b3
commit 7ef5c22ba3
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
dispatch/src/main.go
View File

@@ -98,7 +98,7 @@ func getOrderId(order []byte) string {
return id return id
} }
func createSpan(headers map[string]interface{}, order string) { func createSpan(headers map[string]interface{}, amqpUri string, order string) {
// headers is map[string]interface{} // headers is map[string]interface{}
// carrier is map[string]string // carrier is map[string]string
carrier := make(ot.TextMapCarrier) carrier := make(ot.TextMapCarrier)
@@ -120,9 +120,10 @@ func createSpan(headers map[string]interface{}, order string) {
span = tracer.StartSpan("getOrder", ot.ChildOf(spanContext)) span = tracer.StartSpan("getOrder", ot.ChildOf(spanContext))
span.SetTag(string(ext.SpanKind), ext.SpanKindConsumerEnum) span.SetTag(string(ext.SpanKind), ext.SpanKindConsumerEnum)
span.SetTag(string(ext.MessageBusDestination), "robot-shop") span.SetTag(string(ext.MessageBusDestination), "robot-shop")
span.SetTag("messaging_bus.address", amqpUri)
span.SetTag("exchange", "robot-shop") span.SetTag("exchange", "robot-shop")
span.SetTag("sort", "consume") span.SetTag("sort", "consume")
span.SetTag("address", "rabbitmq") //span.SetTag("address", "rabbitmq")
span.SetTag("key", "orders") span.SetTag("key", "orders")
span.LogFields(otlog.String("orderid", order)) span.LogFields(otlog.String("orderid", order))
defer span.Finish() defer span.Finish()
@@ -250,7 +251,7 @@ func main() {
log.Printf("Order %s\n", d.Body) log.Printf("Order %s\n", d.Body)
log.Printf("Headers %v\n", d.Headers) log.Printf("Headers %v\n", d.Headers)
id := getOrderId(d.Body) id := getOrderId(d.Body)
go createSpan(d.Headers, id) go createSpan(d.Headers, amqpUri, id)
} }
} }
}() }()