Skip to content

fix: Queue incoming subscription events across sources - #3245

Open
GautamBytes wants to merge 1 commit into
XRPLF:developfrom
GautamBytes:fix/subscription-message-queue-1624
Open

GautamBytes wants to merge 1 commit into
XRPLF:developfrom
GautamBytes:fix/subscription-message-queue-1624

Conversation

@GautamBytes

@GautamBytes GautamBytes commented Oct 5, 2026 •

Copy link
Copy Markdown
Contributor

Route subscription events from all ETL sources through a shared queue to prevent losses during handoffs and deduplicate matching messages.

Fixes #1624

@GautamBytes

Copy link
Copy Markdown
Contributor Author

@kuznetsss

@mathbunnyru

Copy link
Copy Markdown
Collaborator

@GautamBytes could you please resolve conflicts and also make sure tests pass?

@GautamBytes
GautamBytes force-pushed the fix/subscription-message-queue-1624 branch from f531503 to 6e52684 Compare October 16, 2026 17:44
@codecov

codecov Bot commented Oct 16, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 84.93151% with 11 lines in your changes missing coverage. Please review.

Files with missing lines Patch % Lines
src/etl/impl/SubscriptionMessageQueue.cpp 84.61% 3 Missing and 7 partials ⚠️
src/etl/Source.cpp 0.00% 1 Missing ⚠️

📢 Thoughts on this report? Let us know!

This branch has not been deployed

No deployments
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Queue for incoming messages from subscriptions

2 participants