You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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} */privateSendResultsyncSend(Stringdestination, Message<?> message, longtimeout, longdelayTime, DelayModemode) {
// ......
}
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
The text was updated successfully, but these errors were encountered:
Before Creating the Enhancement Request
Summary
Multiple overloaded methods of
RocketMQTemplate#syncSendDelayTimeSeconds
do not support a customtimeout
parameter.The
RocketMQTemplate#syncSend
method that supports custom configurations is private.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 theRocketMQTemplate#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 theRocketMQTemplate#syncSend
method to public.If you agree with this enhancement, I can submit a PR.
Additional Context
No response
The text was updated successfully, but these errors were encountered: