Mule 不会在 Rabbitmq 的某些队列中创建消费者
Mule does not create consumers in some queues on Rabbitmq
我正在开发 mule 3.5、rabbitmq connector 3.6 和 RabbitMQ 3.6.0 当我部署我的应用程序时,mule 不会在我的队列中创建一些消费者,但如果我多次重新部署我的应用程序,它会创建所有完全听众。
这是我的部分代码:
Amqp 连接器:
<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 中的队列,我可以看到交换器将消息放入队列并且队列深度增加但是在 rabbitmq 浏览器中没有监听队列的消费者因此,mule 不能处理它。
问题是一些队列侦听器在 AmqpMessageReceiver 初始化之前注册了。我更改了 xml 订单,问题解决了。
我正在开发 mule 3.5、rabbitmq connector 3.6 和 RabbitMQ 3.6.0 当我部署我的应用程序时,mule 不会在我的队列中创建一些消费者,但如果我多次重新部署我的应用程序,它会创建所有完全听众。
这是我的部分代码:
Amqp 连接器:
<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 中的队列,我可以看到交换器将消息放入队列并且队列深度增加但是在 rabbitmq 浏览器中没有监听队列的消费者因此,mule 不能处理它。
问题是一些队列侦听器在 AmqpMessageReceiver 初始化之前注册了。我更改了 xml 订单,问题解决了。