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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
# Copyright (C) 2007-2009 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/>.
"""Interface for switchboards."""
from __future__ import absolute_import, unicode_literals
__metaclass__ = type
__all__ = [
'ISwitchboard',
]
from zope.interface import Interface, Attribute
class ISwitchboard(Interface):
"""The switchboard."""
name = Attribute(
"""The name of the switchboard's queue.""")
queue_directory = Attribute(
"""The queue directory this switchboard is responsible for.
This should be a subdirectory of the system-wide top-level queue
directory.
""")
def enqueue(_msg, _metadata=None, **_kws):
"""Store the message and metadata in the switchboard's queue.
When metadata is not given, an empty metadata dictionary is used. The
keyword arguments are added to the metadata dictonary, with precedence
given to the keyword arguments.
The base name of the message file is returned.
"""
def dequeue(filebase):
"""Return the message and metadata contained in the named file.
filebase is the base name of the message file as returned by the
.enqueue() method. This file must exist and contain a message and
metadata. The message file is preserved in a backup file, which must
be removed by calling the .finish() method.
Returned is a 2-tuple of the form (message, metadata).
"""
def finish(filebase, preserve=False):
"""Remove the backup file for filebase.
If preserve is True, then the backup file is actually just renamed to
a preservation file instead of being unlinked.
"""
files = Attribute(
"""An iterator over all the .pck files in the queue directory.
The base names of the matching files are returned.
""")
def get_files(extension='.pck'):
"""Like the 'files' attribute, but accepts an alternative extension.
Only the files in the queue directory that have a matching extension
are returned. Like 'files', the base names of the matching files are
returned.
"""
def recover_backup_files():
"""Move all backup files to active message files.
It is impossible for both the .bak and .pck files to exist at the same
time, so moving them is enough to ensure that a normal dequeing
operation will handle them.
"""
|
