Search code examples
rabbitmqwso2wso2-api-managerwso2-enterprise-integrator

RabbitMQ connction is getting fail in WSO2 Micro Integrator, what is the way to connect to server?


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)

Solution

  • 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