Skip to content

Commit e28ca51

Browse files
dboschmzarusz
authored andcommitted
fix: add null check for sqs message attributes
Signed-off-by: David Boschmann <davidboschmann@live.de>
1 parent 81a501a commit e28ca51

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/SlimMessageBus.Host.AmazonSQS/Consumer/SqsBaseConsumer.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -169,8 +169,8 @@ private void GetPayloadAndHeadersFromMessage(Message message, out string message
169169
else
170170
{
171171
messagePayload = message.Body;
172-
messageHeaders = message.MessageAttributes
173-
.ToDictionary(x => x.Key, x => HeaderSerializer.Deserialize(x.Key, x.Value));
172+
messageHeaders = message.MessageAttributes?
173+
.ToDictionary(x => x.Key, x => HeaderSerializer.Deserialize(x.Key, x.Value)) ?? new Dictionary<string, object>();
174174
}
175175
}
176176
}

0 commit comments

Comments
 (0)