resque-worker.pl

#!/usr/bin/env perl

use strict;
use Resque;
use Company::Config;
use Getopt::Long::Descriptive;
require UNIVERSAL::require;

my $opt = getopt();
$_->require for @{$opt->module||[]};

my $w = Resque->new( redis => Company::Config->new->redis )->worker;
$w->interval($opt->interval);
$w->add_queue(@{$opt->queue});
$w->verbose($opt->verbose);
$w->cant_fork($opt->cant_fork);
$w->work;

sub getopt {
    my ($opt, $usage) = describe_options(
        'resque-worker %o <some-arg>',
        [ 'queue|q=s@',   "queue name (Default: test)", { default => 'test' } ],
        [ 'interval|i=f', "Polling interval in floating seconds for this resque worker (Default 5 seconds)", { default => 5 } ],
        [ 'cant_fork|f',  "Don't let resque fork" ],
        [ 'module|M=s@',  "Modules to load before forking occurs" ],
        [ 'verbose|v',    "set resque worker to be verbose" ],
        [ 'help',         "print usage message and exit" ],
    );

    print($usage->text), exit if $opt->help;
    return $opt;
}