Connection Issue With AWS RabbitMQ(SSL 5671)

[minhas270]

Hi
I'm facing the issue with connecting AWS RabbitMQ instance it looks like the issue with conductor, not connecting SSL port(5671) and it's connected fine with local instance port 5672.

If I edit and use this factory.useSslProtocol(); in AMQPObservableQueue.java then it's able to connect with AWS RabbitMQ successfully.

Is there I'm missing some configuration? OR any other help would be appreciated. Thank you.

Conductor Version : V3.4.2

Property Example:

conductor.event-queues.amqp.enabled=true
conductor.event-queues.amqp.hosts=vbsdfsdf.amazonaws.com
conductor.event-queues.amqp.username=
conductor.event-queues.amqp.password=
conductor.event-queues.amqp.port=5671

Expception:

java.net.ConnectException: Connection timed out: connect
	at java.net.PlainSocketImpl.waitForConnect(Native Method) ~[?:?]
	at java.net.PlainSocketImpl.socketConnect(PlainSocketImpl.java:107) ~[?:?]
	at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:399) ~[?:?]
	at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:242) ~[?:?]
	at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:224) ~[?:?]
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:403) ~[?:?]
	at java.net.Socket.connect(Socket.java:591) ~[?:?]
	at com.rabbitmq.client.impl.SocketFrameHandlerFactory.create(SocketFrameHandlerFactory.java:60) ~[amqp-client-5.13.0.jar:5.13.0]
	at com.rabbitmq.client.impl.recovery.RecoveryAwareAMQConnectionFactory.newConnection(RecoveryAwareAMQConnectionFactory.java:63) ~[amqp-client-5.13.0.jar:5.13.0]
	at com.rabbitmq.client.impl.recovery.AutorecoveringConnection.init(AutorecoveringConnection.java:160) ~[amqp-client-5.13.0.jar:5.13.0]
	at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1216) ~[amqp-client-5.13.0.jar:5.13.0]
	at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1173) ~[amqp-client-5.13.0.jar:5.13.0]
	at com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:1034) ~[amqp-client-5.13.0.jar:5.13.0]
	at com.netflix.conductor.contribs.queue.amqp.AMQPConnection.createConnection(AMQPConnection.java:77) ~[main/:?]
	at com.netflix.conductor.contribs.queue.amqp.AMQPConnection.getOrCreatePublisherChannel(AMQPConnection.java:201) ~[main/:?]
	at com.netflix.conductor.contribs.queue.amqp.AMQPConnection.getOrCreateChannel(AMQPConnection.java:143) ~[main/:?]
	at com.netflix.conductor.contribs.queue.amqp.AMQPObservableQueue.getOrCreateQueue(AMQPObservableQueue.java:453) ~[main/:?]
	at com.netflix.conductor.contribs.queue.amqp.AMQPObservableQueue.publish(AMQPObservableQueue.java:237) ~[main/:?]
	at com.netflix.conductor.core.execution.tasks.Event.start(Event.java:69) ~[main/:?]
	at com.netflix.conductor.core.execution.AsyncSystemTaskExecutor.execute(AsyncSystemTaskExecutor.java:148) ~[main/:?]
	at com.netflix.conductor.core.execution.tasks.SystemTaskWorker.lambda$pollAndExecute$1(SystemTaskWorker.java:146) ~[main/:?]
	at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1736) [?:?]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) [?:?]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) [?:?]
	at java.lang.Thread.run(Thread.java:834) [?:?]
183717 [system-task-worker-1] ERROR com.netflix.conductor.core.execution.tasks.Event [] - Error executing task: 079a57aa-c86f-43b4-8082-426505c38597, workflow: e9896806-b30e-4ebf-af39-15512d06ba4c
java.lang.RuntimeException: IO error while connecting to b-cc234234235fgsddf0.mq.us-east-1.amazonaws.com
	at com.netflix.conductor.contribs.queue.amqp.AMQPConnection.createConnection(AMQPConnection.java:121) ~[main/:?]