Skip to content

Commit 82f9071

Browse files
authored
Merge pull request #10 from migueltotti/feat/add-routing-key-into-message-application-properties
FEAT: add RoutingKey property in IServiceBusMessage and into ServiceBusMessage applicationProperties
2 parents 45ac73b + 8415ff4 commit 82f9071

2 files changed

Lines changed: 3 additions & 0 deletions

File tree

src/AzureServiceBusFlow/Abstractions/IServiceBusMessage.cs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,5 +3,6 @@
33
public interface IServiceBusMessage
44
{
55
DateTime CreatedDate { get; }
6+
string RoutingKey { get; }
67
}
78
}

src/AzureServiceBusFlow/Producers/ServiceBusProducer.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,7 @@ public async Task ProduceAsync(TMessage message, CancellationToken cancellationT
3636
{
3737
{ "MessageType", message.GetType().Name },
3838
{ "CreatedAt", message.CreatedDate.ToString("O") },
39+
{ "RoutingKey", message.RoutingKey }
3940
}
4041
};
4142

@@ -76,6 +77,7 @@ public async Task ProduceAsync(TMessage message, MessageOptions producerOptions,
7677
{
7778
{ "MessageType", message.GetType().Name },
7879
{ "CreatedAt", (message as IServiceBusMessage)?.CreatedDate.ToString("O") ?? DateTime.UtcNow.ToString("O") },
80+
{ "RoutingKey", (message as IServiceBusMessage)?.RoutingKey ?? Guid.NewGuid().ToString() }
7981
}
8082
};
8183

0 commit comments

Comments
 (0)