Timeout configuration in rabbitmq-jms

[rabbitmqjmsuser]

I am using rabbitmq-jms. Sometimes the connection attempt fails with a connection timeout.   

RMQConnectionFactory which I am using doesn't have any method to set the connection timeout.

https://github.com/rabbitmq/rabbitmq-jms-client/blob/main/src/main/java/com/rabbitmq/jms/admin/RMQConnectionFactory.java

Could someone let me know how to set the connection timeout?

com.rabbitmq.jms.util.RMQJMSException: Timed out establishing RabbitMQ Connection

        at com.rabbitmq.jms.admin.RMQConnectionFactory.instantiateNodeConnection(RMQConnectionFactory.java:321)

        at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:265)

        at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:231)

        at com.rabbitmq.jms.admin.RMQConnectionFactory.createConnection(RMQConnectionFactory.java:218)

        at com.rabbitmq.jms.admin.RMQConnectionFactory.createTopicConnection(RMQConnectionFactory.java:655)

[Arnaud Cogoluègnes]

There is the RMQConnectionFactory#setAmqpConnectionFactoryPostProcessor(Consumer<ConnectionFactory>) callback to customize the AMQP 091 ConnectionFactory. Then use ConnectionFactory#setConnectionTimeout(int) (in milliseconds).

[rabbitmqjmsuser]

Thanks a lot for the pointer. But RMQConnectionFactory doesnt seem to have a method to access the underlying amqconnectionfactory. ( Where we can set the connection timeout)

I have something like this.

RMQConnectionFactory factory = new RMQConnectionFactory();

factory.setHost(), setUser() etc etc.

In order to do a factory. setAmqpConnectionFactoryPostProcessor, I need to get amqconnectionfactory. How do I do it? ( I dont think we should do a new of amqconnectionfactory here)

Thanks

[Arnaud Cogoluègnes]

The post-processor is a callback: pass your own implementation of Consumer<ConnectionFactory> and it will be called before a connection is created. The callback argument is the connection factory instance, you can call the methods you need there.

[Ganesh Udupa]

Thanks a lot. That worked

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To view this discussion, visit https://groups.google.com/d/msgid/rabbitmq-users/6e75365a-3cd7-46a3-89d5-59cfba32f9c5n%40googlegroups.com.