1 changed file
src/Intellias.CQRS.Messaging.AzureServiceBus/Commands | ||
QueueCommandBus.cs | ||
QueueCommandBus.cs
/src/Intellias.CQRS.Messaging.AzureServiceBus/Commands/QueueCommandBus.cs-1+1/src/Intellias.CQRS.Messaging.AzureServiceBus/Commands/QueueCommandBus.cs
Add comment 48 {
Add comment 49 MessageId = command.Id,
Add comment 50 ContentType = command.GetType().AssemblyQualifiedName,
Add comment 51 Minus PartitionKey = command.AggregateRootId,
Add comment 51 Plus PartitionKey = options.GetPartition(command),
Add comment 52 CorrelationId = command.CorrelationId,
Add comment 53 SessionId = options.GetPartition(command),
Add comment 54 Label = command.GetType().Name