Allow user to set custom message queue connection args (#13)

* Allow users to set custom arguments for MQ in config

* Update config docs

Author: gfrn

README.rst

@@ -36,6 +36,7 @@ As for the JSON configuration file, details are as follows:
     - queue: Queue name
     - vhost: Message queue virtual host
     - consumer_queue: Queue to consume messages from (for notifications)
+    - arguments: Connection arguments
 - ispyb
     - pool: Connection pool size
     - overflow: Connection pool overflow max size

config.json

@@ -30,7 +30,10 @@
     "port": 5672,
     "queue": "processing_recipe",
     "vhost": "/",
-    "consumer_queue": "pato_notification"
+    "consumer_queue": "pato_notification",
+    "arguments": {
+      "x-dead-letter-exchange": ""
+    }
   },
   "ispyb": { "pool": 3, "overflow": 6 },
   "facility": {

src/pato/utils/config.py

@@ -45,6 +45,7 @@ class MQ:
     host: str
     port: int
     queue: str
+    arguments: dict[str, str | int]
     user: str = "guest"
     password: str = "guest"
     vhost: str = "zocalo"

src/pato/utils/pika.py

@@ -35,7 +35,7 @@ def consume(
             Config.mq.consumer_queue,
             exclusive=False,
             durable=True,
-            arguments={"x-queue-type": "quorum"},
+            arguments=Config.mq.arguments,
         )
         queue = result.method.queue
         self.channel.queue_bind(