我们计划在我们的应用程序中使用 NServiceBus 来调度消息。在我们的例子中,每条消息都有timeToLive
属性,定义了应该处理该消息的时间段。
对于第一次尝试消息处理不成功的情况,我们的计划是将其移动到特定的重试存储(重试队列),然后在成功处理或timeToLive
过期时重试消息(重试之间有一些超时)。
如果 timeToLive
过期,我们计划记录消息内容并丢弃消息。
实际上,这种重试行为主要是由我们正在实现的协议决定的。
有没有办法用 NServiceBus 实现这种行为?我明白了,不成功的消息会发送到特定的error queue
. 是否可以创建一个单独的总线,指向错误队列?