[Enhancement] Enhance the send delayed message interface to include a message send timeout.
まだ誰も着手していません。
評価
- 難易度
- 3/5
- 見積もり時間
- 1〜2日
- 初心者へのやさしさ
- 55/100
- issue の種類
- 機能追加
- 明瞭さ
- おおむね明確
- 活発さ
- 静か
- 技術スタック
- java
調査の方向性
まず RocketMQTemplate と syncSendDelayTimeSeconds のオーバーロードを見つけ、次に issue に示されている private な syncSend メソッドを読んで、timeout と delay mode がどのように渡されるかを理解します。既存の遅延送信の動作と、存在する場合は関連するテストを確認します。遅延メッセージの呼び出し元が public interface を通じてカスタムの送信 timeout を指定でき、選択した API アプローチがテストによって文書化されていれば完了です。
索引モデルが issue の本文から書いたものです。
説明
Before Creating the Enhancement Request
- I have confirmed that this should be classified as an enhancement rather than a bug/feature.
Summary
Multiple overloaded methods of RocketMQTemplate#syncSendDelayTimeSeconds do not support a custom timeout parameter.
The RocketMQTemplate#syncSend method that supports custom configurations is private.
/**
* Same to {@link #syncSend(String, Message)} with send timeout and delay time specified in addition.
* This function is only valid when the broker version is 5.0 or above
*
* @param destination formats: `topicName:tags`
* @param message {@link org.springframework.messaging.Message}
* @param timeout send timeout with millis
* @param delayTime delay time for message
* @return {@link SendResult}
*/
private SendResult syncSend(String destination, Message<?> message, long timeout, long delayTime, DelayMode mode) {
// ......
}
Motivation
Hope to include a custom timeout parameter when sending any delayed messages.
Describe the Solution You'd Like
Add an additional overloaded method for RocketMQTemplate#syncSendDelayTimeSeconds, or change the visibility of the RocketMQTemplate#syncSend method to public.
If you agree with this enhancement, I can submit a PR.
Describe Alternatives You've Considered
Add an additional overloaded method for RocketMQTemplate#syncSendDelayTimeSeconds, or change the visibility of the RocketMQTemplate#syncSend method to public.
If you agree with this enhancement, I can submit a PR.
Additional Context
No response
- 主要言語
- Java
- スター
- 2.3k
- フォーク
- 941
- PR マージ指標
- 30日以内にマージされた PR はありません
環境構築
- Dockerfile・Docker Compose ファイルなし
- プルリクエストのテンプレートあり
- コントリビューションガイドなし
はじめの一歩
- issue を最後まで読み、次にプロジェクトのコントリビューションガイドを読みます。
- 着手することを issue にコメントします — 二人が同じ作業をするのを防げます。
- リポジトリをフォークし、ブランチを切って変更します。
- issue 番号を参照したプルリクエストを送ります。
apache/rocketmq-spring のほかの issue
-
[Bug] RocketMQClientTemplate.receiveAsync closes the shared SimpleConsumer, breaking all subsequent operations対応中かも @wang-jiahua が 57 日前に担当しました。 オープン
難易度 2/5 1〜3時間 初心者へのやさしさ 88/100
apache/rocketmq-spring#780 · コメント 3 件 ·
-
编译报错オープン
難易度 2/5 1〜3時間 初心者へのやさしさ 72/100
apache/rocketmq-spring#692 · コメント 1 件 ·
-
難易度 2/5 1〜3時間 初心者へのやさしさ 68/100
apache/rocketmq-spring#678 · コメント 2 件 ·
-
難易度 1/5 1時間未満 初心者へのやさしさ 82/100
apache/rocketmq-spring#670 · コメント 1 件 ·
-
難易度 2/5 1〜3時間 初心者へのやさしさ 62/100
apache/rocketmq-spring#609 · コメント 3 件 ·
apache/rocketmq-spring の issue をすべて見る
似ている issue
-
難易度 2/5 1〜3時間 初心者へのやさしさ 72/100
-
bug/错误
難易度 2/5 1〜3時間 初心者へのやさしさ 64/100
FCL-Team/FoldCraftLauncher#1982 · コメント 2 件 ·
メンテナーはふだん 1 日以内に返信
-
[BUG] micronaut-serde-oracle-jdbc-json brings a second OJDBC driver onto the runtime classpath対応中かも @ZARAYACH が今日担当しました。 オープン
難易度 2/5 1〜3時間 初心者へのやさしさ 72/100
micronaut-projects/micronaut-serialization#1494 · コメント 4 件 ·
メンテナーはふだん 2 日以内に返信
-
難易度 1/5 1〜3時間 初心者へのやさしさ 75/100
-
bug
難易度 2/5 1〜3時間 初心者へのやさしさ 73/100
メンテナーはふだん 2 日以内に返信