diff options
| author | Barry Warsaw | 2009-01-01 12:17:16 -0500 |
|---|---|---|
| committer | Barry Warsaw | 2009-01-01 12:17:16 -0500 |
| commit | 6e22adb521769a666d3db85384d619528d7982a0 (patch) | |
| tree | 4a5b0f04f6ea17ce11d9bed8dadbfed5fe838f48 /mailman/queue/retry.py | |
| parent | 996f7ea88ad5eaee7b7c7df5b113dbf6ce896e55 (diff) | |
| download | mailman-6e22adb521769a666d3db85384d619528d7982a0.tar.gz mailman-6e22adb521769a666d3db85384d619528d7982a0.tar.zst mailman-6e22adb521769a666d3db85384d619528d7982a0.zip | |
Diffstat (limited to 'mailman/queue/retry.py')
| -rw-r--r-- | mailman/queue/retry.py | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/mailman/queue/retry.py b/mailman/queue/retry.py index 03cf86848..d502e3bb9 100644 --- a/mailman/queue/retry.py +++ b/mailman/queue/retry.py @@ -18,23 +18,20 @@ import time from mailman.config import config -from mailman.queue import Runner, Switchboard +from mailman.queue import Runner class RetryRunner(Runner): - QDIR = config.RETRYQUEUE_DIR - SLEEPTIME = config.minutes(15) - def __init__(self, slice=None, numslices=1): Runner.__init__(self, slice, numslices) - self.__outq = Switchboard(config.OUTQUEUE_DIR) + self._outq = config.switchboards['out'] def _dispose(self, mlist, msg, msgdata): # Move it to the out queue for another retry - self.__outq.enqueue(msg, msgdata) + self._outq.enqueue(msg, msgdata) return False def _snooze(self, filecnt): # We always want to snooze - time.sleep(float(self.SLEEPTIME)) + time.sleep(self.sleep_float) |
