summaryrefslogtreecommitdiff
path: root/src/mailman/queue/retry.py
diff options
context:
space:
mode:
Diffstat (limited to 'src/mailman/queue/retry.py')
-rw-r--r--src/mailman/queue/retry.py20
1 files changed, 14 insertions, 6 deletions
diff --git a/src/mailman/queue/retry.py b/src/mailman/queue/retry.py
index 2b5a6afad..d2ca78add 100644
--- a/src/mailman/queue/retry.py
+++ b/src/mailman/queue/retry.py
@@ -15,6 +15,16 @@
# 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
@@ -23,15 +33,13 @@ from mailman.queue import Runner
class RetryRunner(Runner):
- def __init__(self, slice=None, numslices=1):
- Runner.__init__(self, slice, numslices)
- self._outq = config.switchboards['out']
+ """Retry delivery."""
def _dispose(self, mlist, msg, msgdata):
- # Move it to the out queue for another retry
- self._outq.enqueue(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
+ # We always want to snooze.
time.sleep(self.sleep_float)