Question
Instasmart Software Solutions
IN
Last activity: 22 Mar 2019 9:00 EDT
Trying to connect with Rabbit MQ - Listener is unable to connect to the queue
We are trying to connect to Rabbit MQ. The JNDI server is connecting fine. While the listener is not able to connect to the queue. Here is the exception trace.
We are trying to connect to Rabbit MQ. The JNDI server is connecting fine. While the listener is not able to connect to the queue. Here is the exception trace.
2018-10-24 15:12:15,583 [ JMS-Thread-16] [ ] [ ] [ ] ( services.jms.JMSListener) ERROR JMS.RabbitMQListener anupam@mt - Caught JMSException in listener RabbitMQListener
com.rabbitmq.jms.util.RMQJMSException: Timed out establishing RabbitMQ Connection
at com.rabbitmq.jms.admin.RMQConnectionFactory.instantiateNodeConnection(RMQConnectionFactory.java:344) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:284) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:233) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
at com.pega.pegarules.integration.engine.internal.services.jms.JMSListener.initializeConnection(JMSListener.java:1064) ~[printegrint.jar:?]
at com.pega.pegarules.integration.engine.internal.services.jms.JMSListener.runPoller(JMSListener.java:758) ~[printegrint.jar:?]
at com.pega.pegarules.integration.engine.internal.services.jms.JMSListener.run_(JMSListener.java:753) ~[printegrint.jar:?]
at com.pega.pegarules.integration.engine.internal.services.listener.ServiceListenerBaseImpl.run(ServiceListenerBaseImpl.java:454) ~[printegrint.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]
Caused by: java.util.concurrent.TimeoutException
at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:77) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:120) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:494) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:315) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:64) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1095) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1054) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1012) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1170) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.jms.admin.RMQConnectionFactory$4.create(RMQConnectionFactory.java:237) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
at com.rabbitmq.jms.admin.RMQConnectionFactory.instantiateNodeConnection(RMQConnectionFactory.java:328) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
Instasmart Software Solutions
IN
Whats the difference with destinationName and amqpQueueName ?
<Resource name="jms/PegaQueue"
type="javax.jms.Queue"
factory="com.rabbitmq.jms.admin.RMQObjectFactory"
destinationName=""
amqpExchangeName="pegasystems"
amqpRoutingKey="pega.app.*"
amqp="true"
amqpQueueName="Pega.Case.Order.CreateOrUpdate.Request" />
Instasmart Software Solutions
IN
This is the detailed exception
This is the detailed exception
[AMQP Connection Proprietary information hidden:15672] WARN com.rabbitmq.client.impl.ForgivingExceptionHandler - An unexpected connection driver error occured (Exception message: Socket closed)
2018-10-25 10:06:22,341 [ JMS-Thread-16] [ ] [ ] [ ] ( services.jms.JMSListener) ERROR JMS.RabbitMQListener anupam@mt - Caught JMSException in listener RabbitMQListener
com.rabbitmq.jms.util.RMQJMSException: Timed out establishing RabbitMQ Connection
at com.rabbitmq.jms.admin.RMQConnectionFactory.instantiateNodeConnection(RMQConnectionFactory.java:344) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:284) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:233) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
at com.pega.pegarules.integration.engine.internal.services.jms.JMSListener.initializeConnection(JMSListener.java:1064) ~[printegrint.jar:?]
at com.pega.pegarules.integration.engine.internal.services.jms.JMSListener.runPoller(JMSListener.java:758) ~[printegrint.jar:?]
at com.pega.pegarules.integration.engine.internal.services.jms.JMSListener.run_(JMSListener.java:753) ~[printegrint.jar:?]
at com.pega.pegarules.integration.engine.internal.services.listener.ServiceListenerBaseImpl.run(ServiceListenerBaseImpl.java:454) ~[printegrint.jar:?]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_181]
Caused by: java.util.concurrent.TimeoutException
at com.rabbitmq.utility.BlockingCell.get(BlockingCell.java:77) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.utility.BlockingCell.uninterruptibleGet(BlockingCell.java:120) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(BlockingValueOrException.java:36) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(AMQChannel.java:494) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:315) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:64) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:156) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1095) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1054) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1012) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1170) ~[amqp-client-5.4.3.jar:5.4.3]
at com.rabbitmq.jms.admin.RMQConnectionFactory$4.create(RMQConnectionFactory.java:237) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
at com.rabbitmq.jms.admin.RMQConnectionFactory.instantiateNodeConnection(RMQConnectionFactory.java:328) ~[rabbitmq-jms-1.11.0.jar:1.11.0]
Pegasystems Inc.
US
this looks to be the RabbitMQ client code. One suggestion, write a simple standalone jms java client completely outside Pega to verify the same client API calls (run the client on the same host as pega server). If the same error, you can then focus on why socket_close exceptions, could be networking related.