rocketmq收费版 延迟消息是如何实现的?

在开源版本中,延迟消息默认指定了18个级别,但是想了解下收费版本中,可以自定义延迟时间这个机制是怎么实现的?有大佬知道吗?可以交流一下?

目前公司在用的是阿里云的ONS,提供的send方法,可以直接指定delay时间,但是追不到底层的服务端源码,不知道是怎么实现的,我自己猜想,底层可能是基于scheduledThreadPoolExecutor实现的,有大佬知道吗?

不知道你这个问题是否已经解决, 如果还没有解决的话:

如果你已经解决了该问题, 非常希望你能够分享一下解决方案, 以帮助更多的人 ^-^