问题描述
基本上我使用的是 spring boot 版本 2.4.4,spring cloud stream 3.1.2,artemis 作为绑定器,我有一个案例,我需要每 10 秒定期发送一次消息,让我们说一个特定的频道,如果消息发送成功我想做一个操作,比如更新数据库中的记录。
我发现供应商 bean(非响应式)已经在做同样的事情,而无需编写文档 https://docs.spring.io/spring-cloud-stream/docs/3.1.0/reference/html/spring-cloud-stream.html#_suppliers_sources 中提到的任何额外代码,而不是编写调度程序来完成使用 streamBridge 机制发送消息的工作。
那么有什么方法可以让我知道消息是否成功发送以执行某些逻辑,也许是通过实现提供的侦听器或其他方法?
提前致谢
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)