NowChess/NowChessSystems
4
0
Fork 0
Code Issues Pull Requests 2 Packages Projects Releases Wiki Activity

feat(bot-platform): migrate BotRegistry to Redis Streams consumer group #63

Merged
Janis merged 1 commits from feat/NCS-101-botregistry-pubsub-to-streams into main 2026-06-09 21:48:21 +02:00
Conversation 0 Commits 1 Files Changed 4
+145 -21
Janis commented 2026-06-09 13:58:59 +02:00
Member
Copy Link
Copy Source

Replace pub/sub subscribe with XREADGROUP on bot game-start stream.
Remove dual-write from EventPublisher.publishGameStart.
Consumer group: bot-platform-consumer, XACK after forwarding.
Poll loop uses emitter identity to prevent thread leak on re-registration.
Group created with '$' offset — no historical replay on first connect.

Closes NCS-101
https://knockoutwhist.youtrack.cloud/issue/NCS-101

Replace pub/sub subscribe with XREADGROUP on bot game-start stream. Remove dual-write from EventPublisher.publishGameStart. Consumer group: bot-platform-consumer, XACK after forwarding. Poll loop uses emitter identity to prevent thread leak on re-registration. Group created with '$' offset — no historical replay on first connect. Closes NCS-101 https://knockoutwhist.youtrack.cloud/issue/NCS-101
Janis added 1 commit 2026-06-09 13:59:00 +02:00
feat(bot-platform): migrate BotRegistry to Redis Streams consumer group
Build & Test (NowChessSystems) TeamCity build finished
Details
ca83f8bba4 
Replace pub/sub subscribe with XREADGROUP on bot game-start stream.
Remove dual-write from EventPublisher.publishGameStart.
Consumer group: bot-platform-consumer, XACK after forwarding.
Poll loop uses emitter identity to prevent thread leak on re-registration.
Group created with '$' offset — no historical replay on first connect.

Closes NCS-101
https://knockoutwhist.youtrack.cloud/issue/NCS-101
Janis merged commit 0ad2e10999 into main 2026-06-09 21:48:21 +02:00
Janis deleted branch feat/NCS-101-botregistry-pubsub-to-streams 2026-06-09 21:48:22 +02:00
Sign in to join this conversation.
Reviewers
No Reviewers
Labels
No items
No Label
Milestone
No items
No Milestone
Projects
Clear projects
No project
Assignees
Clear assignees
Janis (Janis) lq64 (Leon Hermann) shosho996 (Shahd Lala) svc.teamcity
No Assignees
1 Participants
Notifications
Due Date
No due date set.
Dependencies

No dependencies set.

Reference: NowChess/NowChessSystems#63
Delete Branch "feat/NCS-101-botregistry-pubsub-to-streams"

Deleting a branch is permanent. Although the deleted branch may continue to exist for a short time before it actually gets removed, it CANNOT be undone in most cases. Continue?