Add ws rabbit config

config.py

@@ -21,6 +21,14 @@ class Config:
     rabbit_conn: str = 'amqp://user:password@10.10.8.83:31005/%2f'
     rabbit_queue: str = 'ipd'
 
+    ws_rabbit_params: dict = {
+        'host': '10.10.8.83',
+        'port': 31005,
+        'exchange': 'ipd',
+        'user': 'user',
+        'password': 'password',
+    }
+
     s3_endpoint: str = 'http://10.10.8.83:31006'
     s3_key_id: str = 's57'
     s3_access_key: str = 'd9MMinLF3U8TLSj'

main.py

@@ -577,6 +577,10 @@ def apply_commits(params, files, url):
     con = OOConnectionParams(scheme, Config.oodb_host, Config.oodb_port, Config.oodb_dbname,
                              Config.oodb_username, Config.oodb_passwd, scheme)
     ws = OODBWorkspace.ws(scheme)
+    if Config.ws_rabbit_params and not ws.hasProducer():
+        ws.setProducer(Config.ws_rabbit_params['host'], Config.ws_rabbit_params['port'],
+                       Config.ws_rabbit_params['exchange'], Config.ws_rabbit_params['user'],
+                       Config.ws_rabbit_params['password'])
     ws.setCurrentUser(bnd)
     if branch:
         logging.warning(branch)