运行时访问主题信息

自 2.9 版本起,您可以通过注入提供的 DestinationTopicContainer bean,在运行时访问有关主题链的信息。该接口提供查找链中下一个主题的方法,或者如果配置了某个主题的 DLT,则提供查找 DLT 的方法,以及诸如主题名称、延迟和类型等有用属性。

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

DestinationTopicContainer#getNextDestinationTopicFor() 方法提供的 DestinationTopic 对应于输入主题在链中注册的下一个主题。由于异常分类、尝试次数或单主题固定延迟策略等不同因素,消息将转发到的实际主题可能会有所不同。如果需要考虑这些因素,请使用 DestinationTopicResolver 接口。
© . This site is unofficial and not affiliated with VMware.