You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by Felix Thomas <fe...@gmail.com> on 2015/09/10 15:57:10 UTC

Issue in consuming from a rabbitMQ queue usinh Camel rabbit MQ componenet

hello,

    I get the below error, message, and not able to pint point what exactly
is the issue , if i make the queue as a Publish (to) in camel it works fine
. So not sure why the connection is failing. I am using JAVA DSL .


    2015-09-10 14:49:21,204 [main           ] DEBUG
DefaultManagementAgent         - Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=threadpools,name="RabbitMQEndpoint(0x9597028)"
2015-09-10 14:49:21,204 [main           ] DEBUG
DefaultExecutorServiceManager  - Created new ThreadPool for source:
Endpoint[rabbitmq://localhost/XCHANGE?exchangeType=direct&password=xxxxxx&queue=AQUEUE&routingKey=FA&username=guest]
with name: RabbitMQConsumer. ->
org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@6069db50[Running,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks =
0][RabbitMQConsumer]
2015-09-10 14:49:21,205 [main           ] DEBUG
RabbitMQConsumer               - Using executor
org.apache.camel.util.concurrent.RejectableThreadPoolExecutor@6069db50[Running,
pool size = 0, active threads = 0, queued tasks = 0, completed tasks =
0][RabbitMQConsumer]
2015-09-10 14:49:21,295 [main           ] DEBUG
RabbitMQConsumer               - Created connection: amqp://
guest@127.0.0.1:5672/
2015-09-10 14:49:21,303 [main           ] DEBUG
RabbitMQConsumer               - Created channel: AMQChannel(amqp://
guest@127.0.0.1:5672/,1)
2015-09-10 14:49:21,309 [main           ] INFO
RabbitMQConsumer               - Connection failed, will start background
thread to retry!
java.io.IOException
    at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:106)[amqp-client-3.4.3.jar:]
    at
com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:102)[amqp-client-3.4.3.jar:]
    at
com.rabbitmq.client.impl.AMQChannel.exnWrappingRpc(AMQChannel.java:124)[amqp-client-3.4.3.jar:]
    at
com.rabbitmq.client.impl.ChannelN.exchangeDeclare(ChannelN.java:693)[amqp-client-3.4.3.jar:]
    at
com.rabbitmq.client.impl.ChannelN.exchangeDeclare(ChannelN.java:662)[amqp-client-3.4.3.jar:]
    at
com.rabbitmq.client.impl.ChannelN.exchangeDeclare(ChannelN.java:61)[amqp-client-3.4.3.jar:]
    at
org.apache.camel.component.rabbitmq.RabbitMQEndpoint.declareExchangeAndQueue(RabbitMQEndpoint.java:232)[camel-rabbitmq-2.15.1.jar:2.15.1]
    at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.startConsumers(RabbitMQConsumer.java:94)[camel-rabbitmq-2.15.1.jar:2.15.1]