Hello,
I was using following old URI format and it was working perfectly:
//camel-rabbit:2.19.1
from("rabbitmq://mqServer:9941?" +
"queue=qName" +
"&username=username" +
"&password=password" +
"&vhost=vh" +
"&sslProtocol=TLS" +
"&trustManager=customTrustManager" +
"&declare=false")
.to("log:main?showAll=true");
But then I switched to newer version and it start throwing "The RabbitMQ
channel is not open" and "Connection refused" exceptions:
//camel-rabbit:2.23.1
from("rabbitmq:?" +
"hostname=mqServer" +
"&portNumber=9941" +
"&username=username" +
"&password=password" +
"&vhost=vh" +
"&sslProtocol=TLS" +
"&trustManager=customTrustManager" +
"&queue=qName" +
"&declare=false" +
"")
.to("log:main?showAll=true");
Is there anything that I'm missing?
Note that I'm connecting to default exchange in both above examples. I also
tried explicitly providing the exchange name in newer URI format, but
result is the same "The RabbitMQ channel is not open" and "Connection
refused" exceptions.
//camel-rabbit:2.23.1
from("rabbitmq:mqExchangeName?" +
"hostname=mqServer" +
"&portNumber=9941" +
"&username=username" +
"&password=password" +
"&vhost=vh" +
"&sslProtocol=TLS" +
"&trustManager=customTrustManager" +
"&queue=qName" +
"&declare=false" +
"")
.to("log:main?showAll=true");
How come the same configuration works well in older URI format (older
camel-rabbit version 2.19.1) and not working in newer URI format (newer
camel-rabbit version 2.23.1)?
Does it have to do any thing with the version of RabbitMQ running on the
server side?
*2019-04-01 10:23:01.436 WARN 622 --- [ main]
o.a.c.component.rabbitmq.RabbitConsumer : Unable to open channel for
RabbitMQConsumer. Continuing and will try again*
*java.net.ConnectException: Connection refused (Connection refused)*
* at java.base/java.net.PlainSocketImpl.socketConnect(Native Method)
~[na:na]*
* at
java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:399)
~[na:na]*
* at
java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:242)
~[na:na]*
* at
java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:224)
~[na:na]*
* at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:403)
~[na:na]*
* at java.base/java.net.Socket.connect(Socket.java:591) ~[na:na]*
* at
com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:60)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:62)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1104)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1063)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1021)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1211)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
org.apache.camel.component.rabbitmq.RabbitMQEndpoint.connect(RabbitMQEndpoint.java:231)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.openConnection(RabbitMQConsumer.java:64)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.getConnection(RabbitMQConsumer.java:73)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitConsumer.<init>(RabbitConsumer.java:56)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.createConsumer(RabbitMQConsumer.java:122)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.createConsumers(RabbitMQConsumer.java:94)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.doStart(RabbitMQConsumer.java:174)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3701)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:4019)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3954)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3874)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3638)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3490)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:208)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3249)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3245)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3268)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3245)
~[camel-core-2.20.1.jar:2.20.1]*
* at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3168)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:133)
~[camel-spring-2.20.1.jar:2.20.1]*
* at
org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:174)
~[camel-spring-2.20.1.jar:2.20.1]*
* at
org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:167)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:393)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:347)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:883)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:144)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.refresh(SpringApplication.java:693)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:360)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.run(SpringApplication.java:303)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.run(SpringApplication.java:1118)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.run(SpringApplication.java:1107)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at com.smhumayun.camel.Application.main(Application.java:11)
~[classes/:na]*
*2019-04-01 10:23:01.437 INFO 622 --- [ main]
o.a.c.c.rabbitmq.RabbitMQConsumer : Connection failed starting
consumers, will start background thread to retry!*
*java.io.IOException: The RabbitMQ channel is not open*
* at
org.apache.camel.component.rabbitmq.RabbitConsumer.doStart(RabbitConsumer.java:174)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:75)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.startConsumers(RabbitMQConsumer.java:107)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.doStart(RabbitMQConsumer.java:175)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:3701)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRouteConsumers(DefaultCamelContext.java:4019)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStartRouteConsumers(DefaultCamelContext.java:3954)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3874)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3638)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3490)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:208)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3249)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:3245)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:3268)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:3245)
~[camel-core-2.20.1.jar:2.20.1]*
* at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:3168)
~[camel-core-2.20.1.jar:2.20.1]*
* at
org.apache.camel.spring.SpringCamelContext.start(SpringCamelContext.java:133)
~[camel-spring-2.20.1.jar:2.20.1]*
* at
org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:174)
~[camel-spring-2.20.1.jar:2.20.1]*
* at
org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:167)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:139)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:393)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:347)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:883)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.finishRefresh(EmbeddedWebApplicationContext.java:144)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:546)
~[spring-context-4.3.9.RELEASE.jar:4.3.9.RELEASE]*
* at
org.springframework.boot.context.embedded.EmbeddedWebApplicationContext.refresh(EmbeddedWebApplicationContext.java:122)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.refresh(SpringApplication.java:693)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.refreshContext(SpringApplication.java:360)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.run(SpringApplication.java:303)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.run(SpringApplication.java:1118)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at
org.springframework.boot.SpringApplication.run(SpringApplication.java:1107)
~[spring-boot-1.5.8.RELEASE.jar:1.5.8.RELEASE]*
* at com.smhumayun.camel.Application.main(Application.java:11)
~[classes/:na]*
*2019-04-01 10:23:01.439 INFO 622 --- [abbitMQConsumer]
o.a.c.component.rabbitmq.RabbitConsumer : Attempting to open a new
rabbitMQ channel*
*2019-04-01 10:23:01.443 INFO 622 --- [abbitMQConsumer]
o.a.c.c.rabbitmq.RabbitMQConsumer : Connection failed, will retry in
5000ms*
*java.net.ConnectException: Connection refused (Connection refused)*
* at java.base/java.net.PlainSocketImpl.socketConnect(Native Method)
~[na:na]*
* at
java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:399)
~[na:na]*
* at
java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:242)
~[na:na]*
* at
java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:224)
~[na:na]*
* at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:403)
~[na:na]*
* at java.base/java.net.Socket.connect(Socket.java:591) ~[na:na]*
* at
com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:60)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:62)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1104)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1063)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1021)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1211)
~[amqp-client-5.5.0.jar:5.5.0]*
* at
org.apache.camel.component.rabbitmq.RabbitMQEndpoint.connect(RabbitMQEndpoint.java:231)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.openConnection(RabbitMQConsumer.java:64)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer.getConnection(RabbitMQConsumer.java:73)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitConsumer.reconnect(RabbitConsumer.java:311)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer$StartConsumerCallable.call(RabbitMQConsumer.java:218)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at
org.apache.camel.component.rabbitmq.RabbitMQConsumer$StartConsumerCallable.call(RabbitMQConsumer.java:198)
~[camel-rabbitmq-2.23.1.jar:2.23.1]*
* at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
~[na:na]*
* at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
~[na:na]*
* at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
~[na:na]*
* at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]*
Thanks!
~
smhumayun
