I have created an Inbound endpoint to retrieve messages from the RabbitMQ broker and log them in another sequence, when I am trying in the locally installed RabbitMQ server it works fine, but I couldn't make a connection to the remote RabbitMQ host-:
<?xml version="1.0" encoding="UTF-8"?>
<inboundEndpoint name="QueueInboundEP" onError="Common_Error_Sequence" protocol="rabbitmq" sequence="QueueProcess_Sequence" suspend="false" xmlns="http://ws.apache.org/ns/synapse">
<parameters>
<parameter name="sequential">true</parameter>
<parameter name="coordination">true</parameter>
<parameter name="rabbitmq.connection.factory">AMQPConnectionFactory</parameter>
<parameter name="rabbitmq.server.host.name">rabbitmq-ts.sl</parameter>
<parameter name="rabbitmq.server.port">5672</parameter>
<parameter name="rabbitmq.server.user.name">guest</parameter>
<parameter name="rabbitmq.server.password">#4Jkas$56</parameter>
<parameter name="rabbitmq.queue.name">TestQ</parameter>
<parameter name="rabbitmq.exchange.name">TestQ</parameter>
<parameter name="rabbitmq.queue.routing.key">1234</parameter>
<parameter name="rabbitmq.message.content.type">application/json</parameter>
</parameters>
</inboundEndpoint>
Error Message -:
ERROR {RabbitMQConnectionFactory} - [AMQPConnectionFactory] Error creating connection to RabbitMQ Broker. Reattempting to connect. java.net.ConnectException: Connection timed out: connect
at java.base/java.net.PlainSocketImpl.waitForConnect(Native Method)
at java.base/java.net.PlainSocketImpl.socketConnect(PlainSocketImpl.java:107)
at java.base/java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:399)
at java.base/java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:242)
at java.base/java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:224)
at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:403)
at java.base/java.net.Socket.connect(Socket.java:609)
at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:60)
at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:62)
at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1110)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1067)
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:889)
at org.apache.axis2.transport.rabbitmq.RabbitMQUtils.createConnection(RabbitMQUtils.java:80)
at org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQConnectionFactory.createConnection(RabbitMQConnectionFactory.java:216)
at org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQConsumer.initConsumer(RabbitMQConsumer.java:84)
at org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQConsumer.execute(RabbitMQConsumer.java:71)
at org.wso2.carbon.inbound.endpoint.protocol.rabbitmq.RabbitMQTask.taskExecute(RabbitMQTask.java:43)
at org.wso2.carbon.inbound.endpoint.common.OneTimeTriggerInboundTask.execute(OneTimeTriggerInboundTask.java:47)
at org.wso2.micro.integrator.mediation.ntask.NTaskAdapter.execute(NTaskAdapter.java:105)
at org.wso2.micro.integrator.ntask.core.impl.TaskQuartzJobAdapter.execute(TaskQuartzJobAdapter.java:63)
at org.quartz.core.JobRunShell.run(JobRunShell.java:213)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Your configurations look ok. This seems like a network issue. Do you have any firewalls restricting WSO2 from accessing the Rabbit server? Do the following to debug.
Ping the server and see whether the Hostname resolves
ping -a rabbitmq-ts.sl
If the Hostname is resolvable, telnet and see whether you can connect to the AMQP port
telnet rabbitmq-ts.sl 5672