RabbitMQ扇出交换机故障

我可以使用 Publish/Subscribe RabbitMQ Java教程,并且任何连接的消费者都将收到消息的副本。我希望在连接任何使用者之前创建交换和绑定,而不是动态/编程地声明交换和绑定。我已经通过RabbitMQ管理控制台完成了这项工作。然而,出于某种原因,我的消费者以循环方式接收消息,而不是所有人都接收消息的副本。我错过了什么?以下是一些代码片段:

出版商:

channel.basicPublish("public", "", null, rowId.getBytes("UTF-8"));

消费者:

QueueingConsumer consumer = new QueueingConsumer(channel);
            channel.basicConsume("myqueue", false, consumer);

…在RabbitMQ管理控制台中,我创建了一个类型为“fanout”的交换“public”,并将该交换的绑定设置为“myqueue”。

如果有任何帮助,我将不胜感激!