blob: 8438f2576c670b2abb786599e83e719958596722 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
=============
Queue runners
=============
The queue runners (qrunner) are the processes that move messages around the
Mailman system. Each qrunner is responsible for a slice of the hash space in
a queue directory. It processes all the files in its slice, sleeps a little
while, then wakes up and runs through its queue files again.
Basic architecture
==================
The basic architecture of qrunner is implemented in the base class that all
runners inherit from. This base class implements a .run() method that runs
continuously in a loop until the .stop() method is called.
>>> mlist = create_list('_xtest@example.com')
Here is a very simple derived qrunner class. Queue runners use a
configuration section in the configuration files to determine run
characteristics, such as the queue directory to use. Here we push a
configuration section for the test runner.
>>> config.push('test-runner', """
... [qrunner.test]
... max_restarts: 1
... """)
>>> from mailman.queue import Runner
>>> class TestableRunner(Runner):
... def _dispose(self, mlist, msg, msgdata):
... self.msg = msg
... self.msgdata = msgdata
... return False
...
... def _do_periodic(self):
... self.stop()
...
... def _snooze(self, filecnt):
... return
>>> runner = TestableRunner('test')
This qrunner doesn't do much except run once, storing the message and metadata
on instance variables.
>>> msg = message_from_string("""\
... From: aperson@example.com
... To: _xtest@example.com
...
... A test message.
... """)
>>> switchboard = config.switchboards['test']
>>> filebase = switchboard.enqueue(msg, listname=mlist.fqdn_listname,
... foo='yes', bar='no')
>>> runner.run()
>>> print runner.msg.as_string()
From: aperson@example.com
To: _xtest@example.com
<BLANKLINE>
A test message.
<BLANKLINE>
>>> dump_msgdata(runner.msgdata)
_parsemsg: False
bar : no
foo : yes
lang : en
listname : _xtest@example.com
version : 3
XXX More of the Runner API should be tested.
|
