| | | 1 | | global using DbAckMode = AsyncResponse.Transports.PostgreSQL.PostgreSqlAckMode; |
| | | 2 | | global using DbBackgroundFailureContext = AsyncResponse.Transports.PostgreSQL.PostgreSqlBackgroundFailureContext; |
| | | 3 | | global using DbSubscriberOptions = AsyncResponse.Transports.PostgreSQL.PostgreSqlSubscriberOptions; |
| | | 4 | | global using DbSubscriberRole = AsyncResponse.Transports.PostgreSQL.PostgreSqlSubscriberRole; |
| | | 5 | | global using DbTransportDelivery = AsyncResponse.Transports.PostgreSQL.PostgreSqlTransportDelivery; |
| | | 6 | | global using DbTransportOptions = AsyncResponse.Transports.PostgreSQL.PostgreSqlAsyncResponseTransportOptions; |
| | | 7 | | global using DbTransportOptionsValidator = AsyncResponse.Transports.PostgreSQL.PostgreSqlTransportOptionsValidator; |
| | | 8 | | using Microsoft.Extensions.Logging; |
| | | 9 | | |
| | | 10 | | namespace AsyncResponse.Transports.PostgreSQL; |
| | | 11 | | |
| | | 12 | | /// <summary> |
| | | 13 | | /// Applies acknowledgement, redelivery, and dead-letter policy to PostgreSQL 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 PostgreSqlMessageDispatcher( |
| | | 19 | | Func<PostgreSqlTransportDelivery, CancellationToken, Task> handler, |
| | | 20 | | PostgreSqlAsyncResponseTransportOptions options, |
| | | 21 | | PostgreSqlSubscriberOptions subscriberOptions, |
| | | 22 | | ILogger logger, |
| | | 23 | | PostgreSqlSubscriberRole role, |
| | | 24 | | TimeProvider? timeProvider = null) |
| | 480 | 25 | | : DbMessageDispatcherBase( |
| | 480 | 26 | | handler, |
| | 480 | 27 | | options, |
| | 480 | 28 | | subscriberOptions, |
| | 480 | 29 | | logger, |
| | 480 | 30 | | role, |
| | 480 | 31 | | providerName: "PostgreSQL", |
| | 480 | 32 | | unitNoun: "row", |
| | 480 | 33 | | telemetryName: "postgresql", |
| | 480 | 34 | | timeProvider: timeProvider); |