在运行时访问主题信息

从 2.9 版本开始,您可以通过注入提供的 DestinationTopicContainer bean 在运行时访问有关主题链的信息。此接口提供方法来查找链中下一个主题或配置的 DLT(死信主题),以及主题名称、延迟和类型等有用属性。

作为现实世界的用例示例,您可以使用此类信息,以便控制台应用程序在解决失败处理的原因(例如错误/不一致状态)后,将记录从 DLT 发送回链中的第一个重试主题。

DestinationTopicContainer#getNextDestinationTopicFor() 方法提供的 DestinationTopic 对应于为输入主题在链中注册的下一个主题。由于不同的因素(例如异常分类、尝试次数或单主题固定延迟策略),消息将被转发到的实际主题可能会有所不同。如果您需要权衡这些因素,请使用 DestinationTopicResolver 接口。