Add global partitioning for cluster-wide GroupId concurrency control

[jeremydmiller]

Summary

• Adds global partitioning that ensures no two messages with the same GroupId execute concurrently across an entire application cluster
• Pairs external transport topologies with companion local durable queues — external listeners relay messages to local queues for sequential processing by GroupId
• Smart routing via GlobalPartitionedRoute checks local listener ownership and shortcuts directly to local queues when the exclusive listener is active on the current node
• GlobalPartitionedInterceptor on non-paired external listeners re-routes matching messages through Wolverine's routing for proper partition assignment
• All endpoints (external + local) are forced to EndpointMode.Durable for reliability
• UseSharded* extension methods added to all 8 transports: RabbitMQ, Amazon SQS, Azure Service Bus, Kafka, NATS, Redis, Pulsar, GCP Pub/Sub
• New PartitionedMessageTopology classes for Azure Service Bus, Kafka, NATS, Redis, Pulsar, and GCP Pub/Sub

Core infrastructure

• GlobalPartitionedMessageTopology — orchestrates external + companion local topologies with message subscription matching
• GlobalPartitionedRoute — IMessageRoute with local-vs-remote routing logic
• GlobalPartitionedReceiverBridge — IReceiver that forwards from external listener to companion local queue
• GlobalPartitionedInterceptor — IReceiver decorator for non-paired listeners that re-publishes matching messages

Usage

opts.MessagePartitioning.GlobalPartitioned(gp =>
{
    gp.UseShardedRabbitQueues("orders", 5);
    gp.Message<OrderPlaced>();
    gp.Message<OrderShipped>();
});

Test plan

• 34 unit tests covering GlobalPartitionedMessageTopology, GlobalPartitionedRoute, GlobalPartitionedReceiverBridge, GlobalPartitionedInterceptor, and MessagePartitioningRules
• All 8 transport projects compile successfully
• Integration tests with actual message brokers (requires docker infrastructure)

🤖 Generated with Claude Code