diff --git a/queues/sqs/consumer.go b/queues/sqs/consumer.go index c14ecde081af1d35cf0cac4d068d8c91cb86077c..7c56f8ff9d6a8ef6a33c78d8a035f790b1eb2039 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 e68e84d02d9d934e538a9e88e4a06b682f1bce3f..fd970a95749f1f237ad1e8e5eecc850805f1e785 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)