Skip to content

Commit

Permalink
Fix map initialization when copying message attributes
Browse files Browse the repository at this point in the history
  • Loading branch information
muhammadali-scrti committed May 25, 2023
1 parent 8753301 commit 8af9ab6
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 8af9ab6

Please sign in to comment.