Per message options configuration for IMessagePublisher

[EtherZa]

#340

Adds optional per-message configureOptions callbacks to IMessageBusBuilder.AddSQSPublisher and IMessageBusBuilder.AddSNSPublisher.

With this change, applications using the generic IMessagePublisher can populate SQS- and SNS-specific publish options from the message being sent. This enables scenarios such as publishing to FIFO queues and topics by deriving values like MessageGroupId and MessageDeduplicationId from the message itself, while still using type-based routing through IMessagePublisher.
The change also allows these callbacks to override service-configured defaults for a given publish operation, providing additional flexibility when message-specific behavior is required. Documentation has been updated to describe this capability in the publishing guidance.

Example usage:

builder.Services.AddAWSMessageBus(builder =>
{
    builder.AddSQSPublisher<TransactionInfo>(
        "https://sqs.us-west-2.amazonaws.com/012345678910/MyFifoQueue.fifo",
        configureOptions: (message, options) =>
        {
            options.MessageGroupId = message.TransactionId;
            options.MessageDeduplicationId = message.TransactionId;
        });

    builder.AddSNSPublisher<BidInfo>(
        "arn:aws:sns:us-west-2:012345678910:MyFifoTopic.fifo",
        configureOptions: (message, options) =>
        {
            options.MessageGroupId = message.BidId;
            options.MessageDeduplicationId = message.BidId;
        });
});

By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.

[normj]

I like the idea of this PR. I might be over thinking this but just wondering if a user might need access to the services registered in the DI container. For example use some DI service that would be able to look up the group id based on a customer id on the on the message. In that case the service call might be async so it might be good then for the callbacks to return ValueTask.

[EtherZa]

@normj I have added per-message options configuration for publishing to the EventBridge too. It probably won't have too much real world usage, but it is opt-in and keeps expectations aligned.

IServiceProvider has been added with overloads for Action<...> and Func<..., ValueTask> (syntactic sugar to wrap Action in a Func). It has unfortunately come with some small, but breaking changes for which I have bumped the release from a minor to major (but please review and adjust accordingly).

Breaking changes:

1. MessageRoutingPublisher (IMessagePublisher) is no longer registered as a singleton. The IServiceProvider instance needs to be scoped with the calling class so that it can be passed on to the config action/func.
2. ServiceCollectionExtensions.AddAWSMessageBus was exposing MessageBusBuilder instead of the interface. I suspect that it was an oversight and has been changed to keep the overloads in the interface where possible. If you would like to avoid this change, the overloads can be moved to the MessageBusBuilder class.

These are both technically breaking changes, but may not warrant a full bump.

builder.Services.AddAWSMessageBus(builder =>
{
    // synchronous
    builder.AddSQSPublisher<TransactionInfo>(
        "https://sqs.us-west-2.amazonaws.com/012345678910/MyFifoQueue.fifo",
        configureOptions: (serviceProvider, message, options) =>
        {
            options.MessageGroupId = message.TransactionId;
            options.MessageDeduplicationId = message.TransactionId;
        });

    // asynchronous
    builder.AddSNSPublisher<BidInfo>(
        "arn:aws:sns:us-west-2:012345678910:MyFifoTopic.fifo",
        configureOptions: async (serviceProvider, message, options, cancellationToken) =>
        {
            var service =  serviceProvider.GetRequiredService<SomeService>();
            var messageGroupId = service.GetMessageGroupIdAsync(message, cancellationToken0;

            options.MessageGroupId = messageGroupId;
        });
});

I have left each commit unsquashed to make rollback, etc easier. Please modify/drop as you see fit.