Pulsar support for retry and DLQ by punxrok · Pull Request #1333 · JasperFx/wolverine

punxrok · 2025-03-26T14:20:48Z

Pulsar support for retry and DLQ

3.11 update

… of ugly code

…tterTopic

punxrok · 2025-03-27T12:45:37Z

Hey @jeremydmiller
can you please check #1333, especially the TODO: comments (like in PulsarListener.MoveToErrorsAsync(...)), where I would need some guidance.

…s sync with Pulsar RECONSUMETIMES header

…red endpoints, added first test for it

…on waiting for DLQ envelope

… queue flow)

… MoveToRetryLetterQueueAsync from the lifecycle

jeremydmiller · 2025-04-06T20:03:08Z

@punxrok Couple things:

I'm concerned with how many files got touched here, and you introduced all new concepts into the core framework
How is the retry queue any different than Wolverine's existing re-queue mechanism? Why do we need an all new concept?
Why can't the DLQ fit into Wolverine's existing native DLQ abstractions? Why do we need all new abstractions just for Pulsar?

…be deleted in next commit) with ISupportNativeScheduling for Pulsar's native retry letter functionality.

…m the previously modified code

…viously modified code

…viously modified code - removed DotPulsar.Extensions.Resiliency (retry and delay message functionality was not working properly) and created "in-house" retry and DLQ functionalities

# Conflicts: # src/Transports/Pulsar/Wolverine.Pulsar/PulsarTransportExtensions.cs

Co-authored-by: punxrok <6354783+punxrok@users.noreply.github.com> # Conflicts: # src/Transports/Pulsar/Wolverine.Pulsar.Tests/Wolverine.Pulsar.Tests.csproj # src/Transports/Pulsar/Wolverine.Pulsar/Wolverine.Pulsar.csproj

…guidelines Co-authored-by: punxrok <6354783+punxrok@users.noreply.github.com>

…y constant Co-authored-by: punxrok <6354783+punxrok@users.noreply.github.com>

Pulsar: stabilize native retry/DLQ, add tests - Fix PulsarListener resiliency logic, ack handling, and exception headers - Add retry consumer tracking and IPv4 URL for Podman tests - Disable parallelization for Pulsar integration tests - Add unit tests for resiliency config - Verify PulsarNativeReliabilityTests pass under Podman

…ests The tests were failing due to a race condition where the tracking session completed before all requeued messages were processed, resulting in 0 requeued messages being tracked instead of the expected count.

punxrok · 2026-01-28T13:10:12Z

Hey @jeremydmiller, sorry for such a late reply. I rebased it as you requested (old commits were made on old 4.* Wolverine branch).

jeremydmiller · 2026-01-29T01:19:01Z

@punxrok Hey man, I'm so, so sorry this slipped. I'll try to get this in tomorrow for 5.13.

jeremydmiller · 2026-01-29T01:19:18Z

I'll deal w/ the rebase after your last commits

…ected test

jeremydmiller · 2026-02-06T12:46:57Z

@punxrok This finally got in, but I made a new PR w/ your changes:

#2122

jeremydmiller · 2026-02-06T13:32:49Z

Totally misspoke, NOW it's going to go in soon.

jeremydmiller · 2026-02-06T14:10:18Z

I'm pulling this in now and fixing whatever is up in main. Looks like just Nuget ref problems so far.

punxrok · 2026-02-06T19:25:08Z

Thanks, @jeremydmiller! No worries about the delay at all. I really appreciate you handling the rebase and those NuGet-related fixes.

jeremydmiller · 2026-02-06T19:31:21Z

@punxrok Appreciate your patience. I do pride myself on getting PRs and issues taken care of reasonably quick, but sometimes things do fall through the cracks

punxrok and others added 12 commits March 25, 2025 13:26

Merge pull request #1 from JasperFx/main

55733ef

3.11 update

JasperFx#1326 Pulsar support for native retry and DLQ queues - beware…

4014879

… of ugly code

JasperFx#1326 Pulsar support for native retry and DLQ queues - beware…

e846db9

… of ugly code

JasperFx#1326 Pulsar support for native retry and DLQ queues - beware…

0d14f9b

… of ugly code

JasperFx#1326 Additional constructors for DeadLetterTopic and RetryLe…

9caf90d

…tterTopic

JasperFx#1326 Additional constructors for DeadLetterTopic and RetryLe…

8dd8786

…tterTopic

JasperFx#1326 Additional constructors for DeadLetterTopic and RetryLe…

42890d6

…tterTopic

JasperFx#1326 refactoring

90ad042

JasperFx#1326 refactoring

ab74d4f

JasperFx#1326 fix

d0d1d8c

JasperFx#1326 refactoring for MoveToErrorsAsync

656daf0

JasperFx#1326 fix

f5f844e

Rok Povodnik added 8 commits March 27, 2025 13:49

JasperFx#1326 refactoring

c163b41

JasperFx#1326 added support for ISupportRetryLetterQueue

30def92

JasperFx#1326 refactoring

93baf89

JasperFx#1326 refactoring and some dirty fixes for envelope's Attempt…

5619c31

…s sync with Pulsar RECONSUMETIMES header

JasperFx#1326 refactoring

3d33828

JasperFx#1326 Pulsar support for native retry and DLQ queues in buffe…

971d51e

…red endpoints, added first test for it

JasperFx#1326 bug fixes - better unit test asserts and proper conditi…

8373a44

…on waiting for DLQ envelope

JasperFx#1326 bug fixes - added unit test for only DLQ (without retry…

a6e8204

… queue flow)

punxrok marked this pull request as ready for review March 31, 2025 13:04

JasperFx#1326 refactoring - as Jeremy suggested, I removed the action…

844c8b2

… MoveToRetryLetterQueueAsync from the lifecycle

Rok Povodnik added 6 commits April 14, 2025 11:56

JasperFx#1326 refactoring - substituted ISupportRetryLetterQueue (to …

b50c751

…be deleted in next commit) with ISupportNativeScheduling for Pulsar's native retry letter functionality.

JasperFx#1326 refactoring - removed most of not needed constructs fro…

d4c81ac

…m the previously modified code

JasperFx#1326 refactoring - removed not needed construct from the pre…

ac343d9

…viously modified code

JasperFx#1326 refactoring - removed not needed construct from the pre…

908b4de

…viously modified code - removed DotPulsar.Extensions.Resiliency (retry and delay message functionality was not working properly) and created "in-house" retry and DLQ functionalities

JasperFx#1326 refactoring

58e2100

JasperFx#1326 clean-up

4462d5a

Copilot AI mentioned this pull request Jan 27, 2026

Upgrade DotPulsar to 5.0.0 and extend native retry/DLQ tests punxrok/wolverine#7

Closed

8 tasks

Rok Povodnik and others added 8 commits January 27, 2026 16:40

Merge branch 'main' into backup/pulsar-support-retry-and-DLQ-rebased

b7e8376

# Conflicts: # src/Transports/Pulsar/Wolverine.Pulsar/PulsarTransportExtensions.cs

Upgrade DotPulsar from 4.2.4 to 5.0.0 and update dependencies

373f621

Co-authored-by: punxrok <6354783+punxrok@users.noreply.github.com> # Conflicts: # src/Transports/Pulsar/Wolverine.Pulsar.Tests/Wolverine.Pulsar.Tests.csproj # src/Transports/Pulsar/Wolverine.Pulsar/Wolverine.Pulsar.csproj

Extend Pulsar native retry and DLQ tests following Wolverine testing …

309d0a2

…guidelines Co-authored-by: punxrok <6354783+punxrok@users.noreply.github.com>

Replace magic string with PulsarEnvelopeConstants.DelayTimeMetadataKe…

8d4eeca

…y constant Co-authored-by: punxrok <6354783+punxrok@users.noreply.github.com>

Rebase conflicts resolution.

2a04850

Removed Microsoft.Extensions.ObjectPool from package references

eeba315

Added detailed explanations for verify_retry_delay_intervals_are_resp…

6d2fed0

…ected test

jeremydmiller added this to the 5.15 milestone Feb 4, 2026

jeremydmiller closed this Feb 6, 2026

jeremydmiller reopened this Feb 6, 2026

Merge branch 'main' into pulsar-support-retry-and-DLQ

6a62733

jeremydmiller merged commit 6a62733 into JasperFx:main Feb 6, 2026
2 of 4 checks passed

jeremydmiller mentioned this pull request Feb 6, 2026

5.15 Punchlist #2124

Closed

9 tasks

dependabot bot mentioned this pull request Feb 20, 2026

Bump WolverineFx from 5.14.0 to 5.16.2 RobertLynJA/Blog2#662

Closed

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Comments

Pulsar support for retry and DLQ#1333

Pulsar support for retry and DLQ#1333
jeremydmiller merged 44 commits intoJasperFx:mainfrom
punxrok:pulsar-support-retry-and-DLQ

punxrok commented Mar 26, 2025

Uh oh!

punxrok commented Mar 27, 2025

Uh oh!

jeremydmiller commented Apr 6, 2025

Uh oh!

punxrok commented Jan 28, 2026 •

edited

Loading

Uh oh!

jeremydmiller commented Jan 29, 2026

Uh oh!

jeremydmiller commented Jan 29, 2026

Uh oh!

jeremydmiller commented Feb 6, 2026

Uh oh!

jeremydmiller commented Feb 6, 2026

Uh oh!

jeremydmiller commented Feb 6, 2026

Uh oh!

Uh oh!

punxrok commented Feb 6, 2026

Uh oh!

jeremydmiller commented Feb 6, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

Uh oh!

Comments

Conversation

punxrok commented Mar 26, 2025

Uh oh!

punxrok commented Mar 27, 2025

Uh oh!

jeremydmiller commented Apr 6, 2025

Uh oh!

punxrok commented Jan 28, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

jeremydmiller commented Jan 29, 2026

Uh oh!

jeremydmiller commented Jan 29, 2026

Uh oh!

jeremydmiller commented Feb 6, 2026

Uh oh!

jeremydmiller commented Feb 6, 2026

Uh oh!

jeremydmiller commented Feb 6, 2026

Uh oh!

Uh oh!

punxrok commented Feb 6, 2026

Uh oh!

jeremydmiller commented Feb 6, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

punxrok commented Jan 28, 2026 •

edited

Loading