File Coverage

blib/lib/Qudo/Hook/Notify/ReachMaxRetry.pm

Criterion	Covered	Total	%
statement	9	17	52.9
branch	0	2	0.0
condition	0	3	0.0
subroutine	3	7	42.8
pod	0	3	0.0
total	12	32	37.5

package Qudo::Hook::Notify::ReachMaxRetry;
use strict;
use warnings;
use base 'Qudo::Hook';

sub hook_point { 'post_work' }

sub load {
    my ($class, $klass) = @_;

    $klass->hooks->{post_work}->{'notify_reach_max_retry'} = sub {
        my $job = shift;

        if ($job->is_failed && ( $job->funcname->max_retries <= ($job->retry_cnt) )) {
            $klass->plugin->{logger}->emergency(
                sprintf('%s already retry max!!',$job->funcname)
            );
        }
    };
}

sub unload {
    my ($class, $klass) = @_;

    delete $klass->hooks->{post_work}->{'notify_reach_max_retry'};
}


1;
__END__