消费者侧一能,DLQ + 服务员重放(第2节)

Featurekamo-shared-library
已装运
2026年6月26日 01:48 UTC
作者
Kamo
提交
419acb5

将任何 MLOS 消费者插件的可靠性核心添加到: 处理过的 Event 解开分类账( unique coper name+event id) + Mlos DeadLetter DLQ + Mlos DeadLetter status; 同上Potent EventProcessor( INSERT- or- skip dedup in the handler's tx 这样一个失败的回滚标记; 死字母通过最大尝试而不是回滚; 死Letter 无法处理无法解开的毒药); 死Letter Replayer(通过出框重排出一个 DEAD 字母,作为带有因果关系的 Id 线程 - > 无 msg id-unique/dup-window相撞, 标记 REPLAYED). MlosEventEnvelope 收益 @ Jacksonized 用于来回脱线。 新建@ Compubliconents 共享 mlos. outbox. 启用的选入; repos 在已扫描的包中 。 Live CastramentMlos DubableConcumer(NATS订阅) 被推迟到其第一个混凝土消费者.

所有更改

就像你看到的运输?

每一个都自动更新您工作空间的地盘。 开始自由,看它成长 一周又一周.

永远开始自由查看定价