Merge pull request #21 from ONSdigital/message-logging

Add message id to logging

Author: warrenbailey

_infra/helm/csv-worker/Chart.yaml

@@ -18,4 +18,4 @@ version: 1.0.1
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application.
-appVersion: 1.0.18
+appVersion: 1.0.19

main.go

@@ -52,7 +52,7 @@ func (cw CSVWorker) subscribe(ctx context.Context, client *pubsub.Client) {
 	cctx, cancel := context.WithCancel(ctx)
 	logger.Debug("waiting to receive")
 	err := sub.Receive(cctx, func(ctx context.Context, msg *pubsub.Message) {
-		logger.Info("sample received - processing")
+		logger.Info("sample received - processing", zap.String("messageId", msg.ID))
 		logger.Debug("sample data", zap.String("data", string(msg.Data)))
 
 		if msg.DeliveryAttempt != nil {