我们打算建立一种交换到交换绑定的单向网络。我们的要求是将消息采用的路由附加到其标头,但似乎无法找出哪个交换最后处理了消息。
我已经尝试使用跟踪功能查找信息,并且还存在一个预订内部plugin事件的basic.publish
。但是,所有这些方式都给了我交换[[of first entry。
Erlang方法的拦截/扩展功能要被调用?
示例 +---------+
| |
| POE |
| |
+--+--+---+
| |
+-------+ | | +-------+
| | | | | |
| EX1 +---+ +----+ EX2 |
| | | |
+--+----+ +---+---+
| |
| |
| |
+--+----+ +---+---+
| | | |
| QU1 | | QU2 |
| | | |
+-------+ +-------+
对于以QU2
结尾的消息,我们希望有这样的标题字段:
{... x-route, ["POE", "EX2"] }
[NOTE: RabbitMQ团队监视rabbitmq-users
mailing list,并且有时仅在StackOverflow上回答问题。