From 4cc281196a517ec7eac3ec83c124957fd5bf05b1 Mon Sep 17 00:00:00 2001
From: Jan Semmelink <jan@uafrica.com>
Date: Thu, 14 Oct 2021 11:57:43 +0200
Subject: [PATCH] Add some more debug to sending of SQS events
---
queues/sqs/consumer.go | 5 ++---
service/event.go | 5 +++++
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/queues/sqs/consumer.go b/queues/sqs/consumer.go
index c14ecde..7c56f8f 100644
--- a/queues/sqs/consumer.go
+++ b/queues/sqs/consumer.go
@@ -41,8 +41,7 @@ func NewConsumer(requestIDHeaderKey string, routes map[string]interface{}) queue
}
return consumer{
- Service: service.New(),
- //Logger: logger.New().WithFields(map[string]interface{}{"env": env}),
+ Service: service.New(),
env: env,
router: router,
requestIDHeaderKey: requestIDHeaderKey,
@@ -171,7 +170,7 @@ func (consumer consumer) Handler(baseCtx context.Context, lambdaEvent events.SQS
ctx.WithFields(map[string]interface{}{
"message_index": messageIndex,
"message": message,
- }).Infof("Queue(%s) Start SQS Handler Event: %v", ctx.Event().QueueName, ctx.Event)
+ }).Infof("Queue(%s) Start SQS Handler Event: %v", ctx.Event().QueueName, ctx.Event())
//routing on messageType
sqsHandler, err := consumer.router.Route(messageType)
diff --git a/service/event.go b/service/event.go
index e68e84d..fd970a9 100644
--- a/service/event.go
+++ b/service/event.go
@@ -92,6 +92,11 @@ func (event Event) Send(value interface{}) (string, error) {
}
event.BodyJSON = string(jsonBody)
}
+ event.producer.Debugf("Queue(%s) Sending SQS Event: %v from producer(%T)%+v",
+ event.QueueName,
+ event,
+ event.producer,
+ event.producer)
event.producer.Debugf("Queue(%s) Sending SQS Event: %v",
event.QueueName,
event)
--
GitLab