I'm working on mule 3.5, rabbitmq connector 3.6 and RabbitMQ 3.6.0 When I deploy my application, mule does not create some consumers on my queues, but if I redeploy my app in multiple times it would create all of listeners completely.
Here is part of my code:
Amqp connector:
<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>
Inbound endpoint:
<amqp:inbound-endpoint queueName="${queue.businessSearchRequest}" exchange-pattern="one-way"connector-ref="amqpRabbitMQConnector"/>
Outbound endpoint:
<amqp:outbound-endpoint connector-ref="amqpRabbitMQConnector" exchangeName="${exchange.bizSearchResponse}" exchangeType="topic" exchangeDurable="true" routingKey="${core.routing.key}"/>
Actually, my exchanges bound to my queues in rabbitmq and I can see that the exchange put message to the queue and the queue depth increases but in rabbitmq browser there is no consumer which listens to the queue hence, mule can not process it.