Add some more debug to sending of SQS events

queues/sqs/consumer.go

@@ -42,7 +42,6 @@ func NewConsumer(requestIDHeaderKey string, routes map[string]interface{}) queue
 
 	return consumer{
 		Service:             service.New(),
-		//Logger:              logger.New().WithFields(map[string]interface{}{"env": env}),
 		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)

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)