[client/api] Include rabbitmq vhost field configuration (opencti-#2199)

Author: rlynch-ironnet

pycti/api/opencti_api_connector.py

@@ -27,6 +27,7 @@ def list(self) -> Dict:
                     config {
                         connection {
                             host
+                            vhost
                             use_ssl
                             port
                             user
@@ -82,6 +83,7 @@ def register(self, connector: OpenCTIConnector) -> Dict:
                     config {
                         connection {
                             host
+                            vhost
                             use_ssl
                             port
                             user

pycti/connector/opencti_connector_helper.py

@@ -116,6 +116,7 @@ def __init__(self, helper, config: Dict, callback) -> None:
         self.helper = helper
         self.callback = callback
         self.host = config["connection"]["host"]
+        self.vhost = config["connection"]["vhost"]
         self.use_ssl = config["connection"]["use_ssl"]
         self.port = config["connection"]["port"]
         self.user = config["connection"]["user"]
@@ -192,7 +193,7 @@ def run(self) -> None:
                 self.pika_parameters = pika.ConnectionParameters(
                     host=self.host,
                     port=self.port,
-                    virtual_host="/",
+                    virtual_host=self.vhost,
                     credentials=self.pika_credentials,
                     ssl_options=pika.SSLOptions(create_ssl_context(), self.host)
                     if self.use_ssl
@@ -789,7 +790,7 @@ def send_stix2_bundle(self, bundle, **kwargs) -> list:
         pika_parameters = pika.ConnectionParameters(
             host=self.config["connection"]["host"],
             port=self.config["connection"]["port"],
-            virtual_host="/",
+            virtual_host=self.config["connection"]["vhost"],
             credentials=pika_credentials,
             ssl_options=pika.SSLOptions(
                 create_ssl_context(), self.config["connection"]["host"]