Skip to content

Feature/MSG delayed consumption MSG模式增加延时消费功能#577

Closed
wooln wants to merge 4 commits intodtm-labs:mainfrom
wooln:feature/MSG-delayed-consumption
Closed

Feature/MSG delayed consumption MSG模式增加延时消费功能#577
wooln wants to merge 4 commits intodtm-labs:mainfrom
wooln:feature/MSG-delayed-consumption

Conversation

@wooln
Copy link
Copy Markdown
Contributor

@wooln wooln commented Jan 8, 2026

  1. 客户端prepare时可提供NextCronTime(适配了gPRC和http)
  2. MSG模式的commit时,若全局事务不WaitResult且NextCronTime在当前时间+3秒后,则延迟执行
  3. Unit test Feature/msg init next cron time by wooln · Pull Request #108 · dtm-labs/client-csharp

wooln added 3 commits January 7, 2026 14:32
…iting

Set NextCronTime only when it is nil or zero to preserve existing
scheduled times and prevent unintended cron interval resets during
transaction processing.
只有当没有提供NextCronTime时才初始化,否则使用提供的进行saveNew)
- Use NextCronTime from gRPC during prepare; can be used for MSG delayed consumption
- Add logic to allow delaying consumption by using a custom NextCronTime
- In msg mode, return nil early when NextCronTime is set and after 3 seconds  from current time
@wooln
Copy link
Copy Markdown
Contributor Author

wooln commented Jan 11, 2026

Without modifying the dtm server functionality, I can determine whether to delay execution based on the business effective time during the sub-transaction branch execution. However, this will result in additional useless calls. Refer to the C# unit test PR.
Feature/unit test msg delayed consum by wooln · Pull Request #107 · dtm-labs/client-csharp

@wooln wooln closed this Jan 11, 2026
@wooln wooln deleted the feature/MSG-delayed-consumption branch January 19, 2026 05:22
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.

1 participant