From 7342ceebc6f8bd37443cf4bef364646f7a747d0e Mon Sep 17 00:00:00 2001
From: Guy Baron <guy.baron@wework.com>
Date: Mon, 26 Aug 2019 15:28:55 +0300
Subject: [PATCH] added call to worker.span.Finish() when exiting
 processMessage

---
 gbus/worker.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/gbus/worker.go b/gbus/worker.go
index 5bb6740..5bb83f1 100644
--- a/gbus/worker.go
+++ b/gbus/worker.go
@@ -273,6 +273,7 @@ func (worker *worker) runGlobalHandler(delivery *amqp.Delivery) error {
 func (worker *worker) processMessage(delivery amqp.Delivery, isRPCreply bool) {
 	span, ctx := worker.extractOpenTracingSpan(delivery, "ProcessMessage")
 	worker.span = span
+	defer worker.span.Finish()
 	//catch all error handling so goroutine will not crash
 	defer func() {
 		if r := recover(); r != nil {