Set correlation Id for azure service bus message (#673)

* Update TransportMessage.cs

Added GetCorrelationId to TransportMessage

* Update ITransport.AzureServiceBus.cs

Set CorrelationId for Microsoft.Azure.ServiceBus.Message

src/DotNetCore.CAP.AzureServiceBus/ITransport.AzureServiceBus.cs

@@ -42,7 +42,8 @@ namespace DotNetCore.CAP.AzureServiceBus
                 {
                     MessageId = transportMessage.GetId(),
                     Body = transportMessage.Body,
-                    Label = transportMessage.GetName()
+                    Label = transportMessage.GetName(),
+                    CorrelationId = transportMessage.GetCorrelationId()
                 };
 
                 foreach (var header in transportMessage.Headers)
@@ -86,4 +87,4 @@ namespace DotNetCore.CAP.AzureServiceBus
             }
         }
     }
-}
+}

src/DotNetCore.CAP/Messages/TransportMessage.cs

@@ -43,5 +43,10 @@ namespace DotNetCore.CAP.Messages
         {
             return Headers.TryGetValue(Messages.Headers.Group, out var value) ? value : null;
         }
+        
+        public string GetCorrelationId()
+        {
+            return Headers.TryGetValue(Messages.Headers.CorrelationId, out var value) ? value : null;
+        }
     }
 }