现在有需求需要我写组件把租户信息塞到 rocketMq message 的上下文里,但是我对着 rocketMq5.0 的 sdk 看了半天,没发现能够实现的扩展点(也可能是我没找到,官网也没有说),有大佬指点指点思路吗~
1
mineralsalt May 8, 2023
tag 和 key 不都能可以用么, 或者定义一个数据结构, payload 也能带上租户字段啊
|
2
yuhongtai114514 OP @mineralsalt 我是指能够在不修改发送、监听代码的情况下,能够塞租户信息到 tag 、key 或者 payload 里的 sdk 代码扩展点,类似 servlet 的 filter 接口。比如 feign 调用透传租户信息一般是实现 filter 去在请求到达业务逻辑之前,塞到请求的上下文里
|
3
yuhongtai114514 OP @mineralsalt 说错,不是 filter 接口,是 feign 的 RequestInterceptor
|