Commit 7fabeae2 authored by Savorboard's avatar Savorboard

Add consumer group into header . #502

parent 73949a41
......@@ -160,6 +160,7 @@ namespace DotNetCore.CAP.AzureServiceBus
private Task OnConsumerReceived(Message message, CancellationToken token)
{
var header = message.UserProperties.ToDictionary(x => x.Key, y => y.Value.ToString());
header.Add(Headers.Group, _subscriptionName);
var context = new TransportMessage(header, message.Body);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment