diff options
| author | mkanat%bugzilla.org <> | 2008-12-24 03:43:36 +0000 |
|---|---|---|
| committer | mkanat%bugzilla.org <> | 2008-12-24 03:43:36 +0000 |
| commit | 8a3d4469cc85108a194a78ac95f2a6780d2971eb (patch) | |
| tree | c89a2d8abb28b792bcdcf04ea76291842dd91d59 /Bugzilla/Job | |
| parent | 570ca770d29d7800f79d6789c2b1142e383a348a (diff) | |
| download | bugs-8a3d4469cc85108a194a78ac95f2a6780d2971eb.tar bugs-8a3d4469cc85108a194a78ac95f2a6780d2971eb.tar.gz bugs-8a3d4469cc85108a194a78ac95f2a6780d2971eb.tar.bz2 bugs-8a3d4469cc85108a194a78ac95f2a6780d2971eb.tar.xz bugs-8a3d4469cc85108a194a78ac95f2a6780d2971eb.zip | |
Bug 284184: Allow Bugzilla to use an asynchronous job queue for sending mail.
Patch By Max Kanat-Alexander <mkanat@bugzilla.org> and Mark Smith <mark@plogs.net> r=glob, a=mkanat
Diffstat (limited to 'Bugzilla/Job')
| -rw-r--r-- | Bugzilla/Job/Mailer.pm | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/Bugzilla/Job/Mailer.pm b/Bugzilla/Job/Mailer.pm new file mode 100644 index 000000000..a421c59f2 --- /dev/null +++ b/Bugzilla/Job/Mailer.pm @@ -0,0 +1,56 @@ +# -*- Mode: perl; indent-tabs-mode: nil -*- +# +# The contents of this file are subject to the Mozilla Public +# License Version 1.1 (the "License"); you may not use this file +# except in compliance with the License. You may obtain a copy of +# the License at http://www.mozilla.org/MPL/ +# +# Software distributed under the License is distributed on an "AS +# IS" basis, WITHOUT WARRANTY OF ANY KIND, either express or +# implied. See the License for the specific language governing +# rights and limitations under the License. +# +# The Original Code is the Bugzilla Bug Tracking System. +# +# The Initial Developer of the Original Code is Mozilla Corporation. +# Portions created by the Initial Developer are Copyright (C) 2008 +# Mozilla Corporation. All Rights Reserved. +# +# Contributor(s): +# Mark Smith <mark@mozilla.com> +# Max Kanat-Alexander <mkanat@bugzilla.org> + +package Bugzilla::Job::Mailer; +use Bugzilla::Mailer; +BEGIN { eval "use base qw(TheSchwartz::Worker)"; } + +# The longest we expect a job to possibly take, in seconds. +use constant grab_for => 300; +# We don't want email to fail permanently very easily. Retry for 30 days. +use constant max_retries => 725; + +# The first few retries happen quickly, but after that we wait an hour for +# each retry. +sub retry_delay { + my $num_retries = shift; + if ($num_retries < 5) { + return (10, 30, 60, 300, 600)[$num_retries]; + } + # One hour + return 60*60; +} + +sub work { + my ($class, $job) = @_; + my $msg = $job->arg->{msg}; + my $success = eval { MessageToMTA($msg, 1); 1; }; + if (!$success) { + $job->failed($@); + undef $@; + } + else { + $job->completed; + } +} + +1; |