diff options
| author | bwarsaw | 2002-03-11 04:21:33 +0000 |
|---|---|---|
| committer | bwarsaw | 2002-03-11 04:21:33 +0000 |
| commit | c2572f01d8a3a73055937539adfb17b34bab9b62 (patch) | |
| tree | 1b9cae1ee5e993f294a9089e4e2cb07958ee985e /Mailman/Queue | |
| parent | 44637b09290d6c593ab8e72fd0c819a6d00afd67 (diff) | |
| download | mailman-c2572f01d8a3a73055937539adfb17b34bab9b62.tar.gz mailman-c2572f01d8a3a73055937539adfb17b34bab9b62.tar.zst mailman-c2572f01d8a3a73055937539adfb17b34bab9b62.zip | |
__oneloop(): Stick the queue directory in the message metadata so that
we can unshunt it to the correct queue.
Diffstat (limited to 'Mailman/Queue')
| -rw-r--r-- | Mailman/Queue/Runner.py | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/Mailman/Queue/Runner.py b/Mailman/Queue/Runner.py index 53ab0e006..ffa6b2a8c 100644 --- a/Mailman/Queue/Runner.py +++ b/Mailman/Queue/Runner.py @@ -113,6 +113,8 @@ class Runner: self.__onefile(msg, msgdata) except Exception, e: self._log(e) + # Put a marker in the metadata for unshunting + msgdata['whichq'] = self._switchboard.whichq() self._shunt.enqueue(msg, msgdata) # Other work we want to do each time through the loop Utils.reap(self._kids, once=1) |