diff options
| author | Barry Warsaw | 2011-05-29 16:49:28 -0400 |
|---|---|---|
| committer | Barry Warsaw | 2011-05-29 16:49:28 -0400 |
| commit | 0f85fb344688e1982e9320e79b7fb38eefc1ac53 (patch) | |
| tree | ec6e635e9c0f8a5bd655a254f9c346f1acb6dd8e /src/mailman/runners/retry.py | |
| parent | 0f760798fb2490a03041c42018afbd59749e6cbd (diff) | |
| parent | 521a179d309fac857fdbbe162d5db136c3ec3b1e (diff) | |
| download | mailman-0f85fb344688e1982e9320e79b7fb38eefc1ac53.tar.gz mailman-0f85fb344688e1982e9320e79b7fb38eefc1ac53.tar.zst mailman-0f85fb344688e1982e9320e79b7fb38eefc1ac53.zip | |
Diffstat (limited to 'src/mailman/runners/retry.py')
| -rw-r--r-- | src/mailman/runners/retry.py | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/src/mailman/runners/retry.py b/src/mailman/runners/retry.py new file mode 100644 index 000000000..8b4cfaada --- /dev/null +++ b/src/mailman/runners/retry.py @@ -0,0 +1,45 @@ +# Copyright (C) 2003-2011 by the Free Software Foundation, Inc. +# +# This file is part of GNU Mailman. +# +# GNU Mailman is free software: you can redistribute it and/or modify it under +# the terms of the GNU General Public License as published by the Free +# Software Foundation, either version 3 of the License, or (at your option) +# any later version. +# +# GNU Mailman is distributed in the hope that it will be useful, but WITHOUT +# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or +# FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for +# more details. +# +# You should have received a copy of the GNU General Public License along with +# GNU Mailman. If not, see <http://www.gnu.org/licenses/>. + +"""Retry delivery.""" + +from __future__ import absolute_import, unicode_literals + +__metaclass__ = type +__all__ = [ + 'RetryRunner', + ] + + +import time + +from mailman.config import config +from mailman.core.runner import Runner + + + +class RetryRunner(Runner): + """Retry delivery.""" + + def _dispose(self, mlist, msg, msgdata): + # Move the message to the out queue for another try. + config.switchboards['outgoing'].enqueue(msg, msgdata) + return False + + def _snooze(self, filecnt): + # We always want to snooze. + time.sleep(self.sleep_float) |
