lib/presque/worker/Role/Dispatcher.pm


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

package presque::worker::Role::Dispatcher;

use Moose::Role;
use Try::Tiny;

has fork_dispatcher => (
    is        => 'ro',
    isa       => 'Bool',
    default   => 0,
);

around work => sub {
    my ($orig, $self, $job) = @_;

    try {
        if ($self->fork_dispatcher) {
            $self->_fork_and_work($orig, $job);
        }
        else {
            $self->$orig($job);
        }
    }catch{
        $self->_job_failure($job, $_);
    };
};


sub _fork_and_work {
    my ($self, $orig, $job) = @_;

    my $pid = fork();
    if ($pid == 0) {
        $self->$orig($job);
        exit;
    }
    elsif ($pid > 0) {
        return;
    }
    else {
        # failure
    }
}

1;