From f4436620d7b76e76405b96ec3e7f7389635b80a7 Mon Sep 17 00:00:00 2001 From: Bel LaPointe Date: Mon, 6 Feb 2023 08:21:06 -0700 Subject: [PATCH] debug err log --- main.go | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/main.go b/main.go index 9a1f7ef..d512f25 100644 --- a/main.go +++ b/main.go @@ -131,14 +131,15 @@ func (c Config) Produce(ctx context.Context) error { func (c Config) Consume(ctx context.Context) error { client := sqs.New(session.Must(session.NewSession()), c.awsc()) - messages, err := client.ReceiveMessageWithContext(ctx, &sqs.ReceiveMessageInput{ + input := sqs.ReceiveMessageInput{ QueueUrl: aws.String(c.sqsurl()), MaxNumberOfMessages: aws.Int64(10), VisibilityTimeout: aws.Int64(5), WaitTimeSeconds: aws.Int64(1), - }) + } + messages, err := client.ReceiveMessageWithContext(ctx, &input) if err != nil { - return err + return fmt.Errorf("failed to consume with %+v at %s: %w", c, c.sqsurl(), err) } for _, message := range messages.Messages { var v interface{}