From a59e53cbe79f4440effd1c1aef19074bd2365441 Mon Sep 17 00:00:00 2001
From: jounaidr <jounaid.ruhomaun@stfc.ac.uk>
Date: Mon, 13 Sep 2021 14:42:44 +0100
Subject: [PATCH] Change reject queue to a QueueSimple() when using dirq for
 sender

Signed-off-by: jounaidr <jounaid.ruhomaun@stfc.ac.uk>
---
 ssm/ssm2.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/ssm/ssm2.py b/ssm/ssm2.py
index 0c7e5bb7..5b19e6cc 100644
--- a/ssm/ssm2.py
+++ b/ssm/ssm2.py
@@ -125,7 +125,7 @@ def __init__(self, hosts_and_ports, qpath, cert, key, dest=None, listen=None,
                                       "module wasn't found.")
 
                 self._outq = QueueSimple(outqpath)
-                self._rejectq = MessageDirectory(rejectqpath)
+                self._rejectq = QueueSimple(rejectqpath)
 
             elif path_type == 'directory':
                 self._outq = MessageDirectory(outqpath)