【发布时间】:2013-12-10 19:07:05
【问题描述】:
我对 wso2 消息代理相当陌生,并且正在研究 poc。 我们正在尝试将 WSO2 消息代理与 RabbitMQ C# 一起使用。 当我将队列绑定到扇出交换时,消费者代码中出现错误。 这是错误的代码:
_channel.ExchangeDeclare("amq.fanout", "fanout");
string queueName = _channel.QueueDeclare();
_channel.QueueBind(queueName, "amq.fanout", "");
异常发生在这个sn-p的第三行(QueueBind)。
这是错误 AMQP操作被中断:AMQP close-reason,由Peer发起,code=504, text="org.wso2.andes.AMQSecurityException: Permission denied: binding [error code 403: access denied]", classId=50, methodId= 20、原因=
我们正在使用 AMQP 0_9_1。
我看到 wso2 mb 默认不提供扇出交换。我在 qpid.virtualhosts.xml 文件中添加了以下 sn-p
<exchange>
<type>fanout</type>
<name>amq.fanout</name>
</exchange>
代理启动时,我没有看到任何错误。
我不确定我是否缺少设置或代码中的任何内容,或者 wso2 消息代理是否支持扇出交换? 我也找不到这种情况的任何例子。 任何帮助表示赞赏!
【问题讨论】: