-
[OPIK-846] [BE] Add Redis subscriber message claimer for pending messages (#3797)
frostbyte_neo 发布于
2025-10-30 16:47:36 +00:00 -
[OPIK-846] [BE] Add Redis subscriber message claimer for pending messages
-
Revision 2: Use AtomicInteger for polling tick counter in BaseRedisSubscriber
-
Revision 3: Fix pending message claiming to use XAUTOCLAIM for crashed consumers
-
Revision 4: Add new StreamConfiguration methods to TestStreamConfiguration
-
Revision 5: Align naming conventions across all StreamConfiguration implementations
-
Revision 6: Add pending message claimer configuration to config files
-
Revision 7: Add per-stream override placeholders for pending message claimer configuration
-
Revision 8: Add comprehensive tests for pending message claimer functionality
-
Revision 9: fix unit tests
-
Revision 10: Fix pending message claimer tests with manual pending message creation
-
Manual revision
下载附件
-