aws
/
sns-sqs-test
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

debug err log

master
Bel LaPointe 2023-02-06 08:21:06 -07:00
parent 4beaa4c387
commit f4436620d7
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
main.go
View File

@ -131,14 +131,15 @@ func (c Config) Produce(ctx context.Context) error {
func (c Config) Consume(ctx context.Context) error { func (c Config) Consume(ctx context.Context) error {
client := sqs.New(session.Must(session.NewSession()), c.awsc()) client := sqs.New(session.Must(session.NewSession()), c.awsc())
messages, err := client.ReceiveMessageWithContext(ctx, &sqs.ReceiveMessageInput{ input := sqs.ReceiveMessageInput{
QueueUrl: aws.String(c.sqsurl()), QueueUrl: aws.String(c.sqsurl()),
MaxNumberOfMessages: aws.Int64(10), MaxNumberOfMessages: aws.Int64(10),
VisibilityTimeout: aws.Int64(5), VisibilityTimeout: aws.Int64(5),
WaitTimeSeconds: aws.Int64(1), WaitTimeSeconds: aws.Int64(1),
}) }
messages, err := client.ReceiveMessageWithContext(ctx, &input)
if err != nil { 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 { for _, message := range messages.Messages {
var v interface{} var v interface{}