| | | 1 | | global using DbAckMode = AsyncResponse.Transports.MongoDB.MongoDbAckMode; |
| | | 2 | | global using DbBackgroundFailureContext = AsyncResponse.Transports.MongoDB.MongoDbBackgroundFailureContext; |
| | | 3 | | global using DbSubscriberOptions = AsyncResponse.Transports.MongoDB.MongoDbSubscriberOptions; |
| | | 4 | | global using DbSubscriberRole = AsyncResponse.Transports.MongoDB.MongoDbSubscriberRole; |
| | | 5 | | global using DbTransportDelivery = AsyncResponse.Transports.MongoDB.MongoDbTransportDelivery; |
| | | 6 | | global using DbTransportOptions = AsyncResponse.Transports.MongoDB.MongoDbAsyncResponseTransportOptions; |
| | | 7 | | global using DbTransportOptionsValidator = AsyncResponse.Transports.MongoDB.MongoDbTransportOptionsValidator; |
| | | 8 | | using Microsoft.Extensions.Logging; |
| | | 9 | | |
| | | 10 | | namespace AsyncResponse.Transports.MongoDB; |
| | | 11 | | |
| | | 12 | | /// <summary> |
| | | 13 | | /// Applies acknowledgement, redelivery, and dead-letter policy to MongoDB transport deliveries. |
| | | 14 | | /// All machinery lives in <see cref="DbMessageDispatcherBase"/> (shared source, compiled into this |
| | | 15 | | /// assembly); the global using aliases above bind the provider seam types, and this derivation |
| | | 16 | | /// supplies only the display strings rendered into logs and telemetry. |
| | | 17 | | /// </summary> |
| | | 18 | | internal sealed class MongoDbMessageDispatcher( |
| | | 19 | | Func<MongoDbTransportDelivery, CancellationToken, Task> handler, |
| | | 20 | | MongoDbAsyncResponseTransportOptions options, |
| | | 21 | | MongoDbSubscriberOptions subscriberOptions, |
| | | 22 | | ILogger logger, |
| | | 23 | | MongoDbSubscriberRole role) |
| | 3 | 24 | | : DbMessageDispatcherBase( |
| | 3 | 25 | | handler, |
| | 3 | 26 | | options, |
| | 3 | 27 | | subscriberOptions, |
| | 3 | 28 | | logger, |
| | 3 | 29 | | role, |
| | 3 | 30 | | providerName: "MongoDB", |
| | 3 | 31 | | unitNoun: "document", |
| | 3 | 32 | | telemetryName: "mongodb"); |