Try to fix azure service bus header cast exception. #483

yang-xiaodong · yang-xiaodong · commit 45f1d54cfb21 · 2020-01-19T14:01:27.000+08:00
diff --git a/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerClient.cs b/src/DotNetCore.CAP.AzureServiceBus/AzureServiceBusConsumerClient.cs
@@ -159,7 +159,7 @@ private async Task ConnectAsync()
 
         private Task OnConsumerReceived(Message message, CancellationToken token)
         {
-            var header = message.UserProperties.ToDictionary(x => x.Key, y => y.Value.ToString());
+            var header = message.UserProperties.ToDictionary(x => x.Key, y => y.Value?.ToString());
 
             var context = new TransportMessage(header, message.Body);
 

Original file line number	Diff line number	Diff line change
`@@ -159,7 +159,7 @@ private async Task ConnectAsync()`
`159`	`159`
`160`	`160`	`private Task OnConsumerReceived(Message message, CancellationToken token)`
`161`	`161`	`{`
`162`		`- var header = message.UserProperties.ToDictionary(x => x.Key, y => y.Value.ToString());`
	`162`	`+ var header = message.UserProperties.ToDictionary(x => x.Key, y => y.Value?.ToString());`
`163`	`163`
`164`	`164`	`var context = new TransportMessage(header, message.Body);`
`165`	`165`