From cfdfd967937b7592a438547e466fb9ca6f0b1042 Mon Sep 17 00:00:00 2001
From: Egor Margineanu <egor.margineanu@gmail.com>
Date: Thu, 19 Mar 2020 13:26:59 +0100
Subject: [PATCH] Added support for PG port and options

---
 awx/main/dispatch/__init__.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/awx/main/dispatch/__init__.py b/awx/main/dispatch/__init__.py
index 841f9344ae..300449a77e 100644
--- a/awx/main/dispatch/__init__.py
+++ b/awx/main/dispatch/__init__.py
@@ -75,7 +75,9 @@ def pg_bus_conn():
     conn = psycopg2.connect(dbname=conf['NAME'],
                             host=conf['HOST'],
                             user=conf['USER'],
-                            password=conf['PASSWORD'])
+                            password=conf['PASSWORD'],
+                            port=conf['PORT'],
+                            **conf["OPTIONS"])
     # Django connection.cursor().connection doesn't have autocommit=True on
     conn.set_session(autocommit=True)
     pubsub = PubSub(conn)