騾子不會在RabbitMQ的

創造消費者在一些隊列

我工作的騾子3.5，RabbitMQ的連接器3.6和RabbitMQ的3.6.0當我部署我的應用程序，騾子不會在我的隊列創建一些消費者，但如果我重新部署我的應用程序在多次它將完全創建所有的聽衆。
這裏是我的代碼部分：
AMQP連接器：騾子不會在RabbitMQ的

<amqp:connector name="amqpRabbitMQConnector" host="${rabbitmq.host}" username="${rabbitmq.username}" password="${rabbitmq.password}" validateConnections="true" requestedHeartbeat="60" activeDeclarationsOnly="true">   
<reconnect-forever frequency="2000" blocking="false"/> 
</amqp:connector>

入站端點：

<amqp:inbound-endpoint queueName="${queue.businessSearchRequest}" exchange-pattern="one-way"connector-ref="amqpRabbitMQConnector"/>

出站端點：

<amqp:outbound-endpoint connector-ref="amqpRabbitMQConnector" exchangeName="${exchange.bizSearchResponse}"        exchangeType="topic" exchangeDurable="true" routingKey="${core.routing.key}"/>

其實，我的交流綁定到我的隊列中rabbitmq，我可以看到交換機將消息放入隊列並且隊列深度增加，但在兔子身上mq瀏覽器沒有消費者監聽隊列，因此mule無法處理它。

來源

2016-01-10 Sima

嗨，我認爲你需要提供更多的像騾子版本的連接器版本，您的流量配置文件等細節。否則將很難幫助你。 –

當然，你是對的。我的mule版本是3.5.0，amqpconnector是3.6.2，這是我的連接器： – Sima

@MauroRocco嗨，你是對的。這是我的連接器代碼： <重新-永遠頻率=「2000」阻擋=「假」 /> – Sima

的問題是，一些隊列聽衆AmqpMessageReceiver初始化之前註冊。我改變了我的XML訂單，並解決了問題。

來源

2016-01-13 14:28:03 Sima

騾子不會在RabbitMQ的

回答

相關問題