add tid in log

Financial-Times · Oct 12, 2018 · 66b5db1 · 66b5db1
1 parent 3315b62
commit 66b5db1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/queuehandler.go b/queuehandler.go
@@ -37,11 +37,11 @@ func (h *queueHandler) init() {
 
 func (h *queueHandler) queueConsume(m consumer.Message) {
 	if m.Headers["Origin-System-Id"] != nextVideoOrigin {
-		log.WithField("queue_topic", h.consumerConfig.Topic).Infof("Ignoring message with different Origin-System-Id: %v", m.Headers["Origin-System-Id"])
+		log.WithTransactionID(m.Headers["X-Request-Id"]).WithField("queue_topic", h.consumerConfig.Topic).Infof("Ignoring message with different Origin-System-Id: %v", m.Headers["Origin-System-Id"])
 		return
 	}
 	if strings.Contains(m.Headers["Content-Type"], "audio") {
-		log.WithField("queue_topic", h.consumerConfig.Topic).Infof("Ignoring message with Content-Type: %v", m.Headers["Content-Type"])
+		log.WithTransactionID(m.Headers["X-Request-Id"]).WithField("queue_topic", h.consumerConfig.Topic).Infof("Ignoring message with Content-Type: %v", m.Headers["Content-Type"])
 		return
 	}
 	lastModified := m.Headers["Message-Timestamp"]