Skip to content

[Mocha] Configure receive resilience on PostgreSQL queues - #10509

Merged
PascalSenn merged 1 commit into
pse/mocha-configurable-inmemory-queuefrom
pse/mocha-configurable-postgres-queue
Oct 9, 2026
Merged

PascalSenn merged 1 commit into
pse/mocha-configurable-inmemory-queuefrom
pse/mocha-configurable-postgres-queue

Conversation

@PascalSenn

Copy link
Copy Markdown
Member

The PostgreSQL Queue(...) descriptor implements
IConfigurable and replays the recorded
callbacks onto the queue's receive endpoint.


Stack created with GitHub Stacks CLI • Give Feedback 💬

@github-actions

github-actions Bot commented Oct 8, 2026 •

Copy link
Copy Markdown
Contributor

Patch coverage

100.0% of changed lines covered (9/9)

File Covered Changed Patch %
…/Configurations/PostgresQueueDescriptorConfiguration.cs 1 1 100.0% 🟢
…/Descriptors/PostgresMessagingTransportDescriptor.cs 4 4 100.0% 🟢
…/Descriptors/PostgresQueueDescriptor.cs 4 4 100.0% 🟢

Project coverage: 58.6% (314230/536441 lines)

Copilot AI balanced review requested due to automatic review settings October 8, 2026 20:15
@PascalSenn
PascalSenn force-pushed the pse/mocha-configurable-postgres-queue branch from a28a23f to f14ad26 Compare October 8, 2026 20:15

Copilot AI left a comment

Copy link
Copy Markdown
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

🟢 Approval recommended

The implementation follows established transport patterns and includes focused behavioral coverage.

0 open findings

What changed in this PR

Adds PostgreSQL queue-level receive resilience configuration, aligned with other Mocha transports.

Changes:

  • Records and replays receive middleware callbacks onto materialized endpoints.
  • Adds resilience and endpoint-merging coverage.
File Description
PostgresUnifiedQueueTests.cs Tests queue resilience propagation and policy merging.
PostgresQueueDescriptor.cs Records receive configuration callbacks.
PostgresMessagingTransportDescriptor.cs Replays callbacks onto the endpoint.
IPostgresQueueDescriptor.cs Exposes receive configuration support.
PostgresQueueDescriptorConfiguration.cs Stores callbacks in registration order.

🧠 Review effort: Balanced


💡 Add a code-review agent skill or configure MCP servers for context-aware, tailored reviews. Learn more in the docs.

The PostgreSQL Queue(...) descriptor implements
IConfigurable<IReceiveMiddlewareProvider> and replays the recorded
callbacks onto the queue's receive endpoint.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants