Change reject queue to a QueueSimple() when using dirq for sender

Signed-off-by: jounaidr <[email protected]>
apel · Dec 12, 2022 · 4f9c095 · 4f9c095
1 parent 61851f3
commit 4f9c095
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ssm/ssm2.py b/ssm/ssm2.py
@@ -127,7 +127,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)