运行时访问主题信息
自 2.9 版本以来,您可以通过注入提供的 DestinationTopicContainer
bean 在运行时访问有关主题链的信息。该接口提供了查找链中下一个主题或如果已配置的主题的 DLT 的方法,以及一些有用的属性,例如主题的名称、延迟和类型。
作为一个现实世界的用例示例,您可以使用这些信息,使控制台应用程序在解决了导致处理失败的原因(例如,错误 / 不一致状态)后,将记录从 DLT 重新发送到链中的第一个重试主题。
important
DestinationTopicContainer#getNextDestinationTopicFor()
方法提供的 DestinationTopic
对应于输入主题在链中注册的下一个主题。消息将被转发到的实际主题可能会因不同因素而有所不同,例如异常分类、尝试次数或单主题固定延迟策略。如果您需要考虑这些因素,请使用 DestinationTopicResolver
接口。