Skip to content

Commit

Permalink
Merge pull request RichardKnop#16 from pakistancan/master
Browse files Browse the repository at this point in the history
Fix map initialization when copying message attributes
  • Loading branch information
cchigurupati authored May 25, 2023
2 parents 4ac9454 + 81329d7 commit 8947140
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion v1/brokers/sqsv2/sqs.go
Original file line number Diff line number Diff line change
Expand Up @@ -256,7 +256,7 @@ func (b *Broker) consumeOne(sqsReceivedMsgs *ReceivedMessages, taskProcessor ifa
}

// Port changes from https://github.com/securitiai/machinery/pull/11 to sqs v2
var attrs map[string]*string
var attrs = map[string]*string{}
for key, val := range delivery.Messages[0].Attributes {
attrs[key] = aws.String(val)
}
Expand Down

0 comments on commit 8947140

Please sign in to comment.