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{}