41 lines
1.2 KiB
Perl
41 lines
1.2 KiB
Perl
package Pear::LocalLoop::Plugin::Minion;
|
|
use Mojo::Base 'Mojolicious::Plugin';
|
|
|
|
use Mojo::Loader qw/ find_modules load_class /;
|
|
|
|
sub register {
|
|
my ( $plugin, $app, $cong ) = @_;
|
|
|
|
if ( defined $app->config->{minion} ) {
|
|
$app->log->debug('Setting up Minion tasks');
|
|
$app->plugin( 'Minion' => $app->config->{minion} );
|
|
|
|
$app->log->debug('Loaded Minion Job packages:');
|
|
|
|
my $job_namespace = __PACKAGE__ . '::Job';
|
|
my @modules = find_modules $job_namespace;
|
|
for my $package (@modules) {
|
|
my ($job_name) = $package =~ /${job_namespace}::(.*)$/;
|
|
$app->log->debug($package);
|
|
if ( my $e = load_class $package) {
|
|
die ref $e ? "Exception: $e" : "$package not found";
|
|
}
|
|
$app->minion->add_task(
|
|
$job_name => sub {
|
|
my ( $job, @args ) = @_;
|
|
my $job_runner = $package->new( job => $job, );
|
|
$job_runner->run(@args);
|
|
}
|
|
);
|
|
}
|
|
|
|
# $app->minion->enqueue('test' => [ 'test arg 1', 'test_arg 2' ] );
|
|
}
|
|
else {
|
|
$app->log->debug('No Minion Config');
|
|
}
|
|
|
|
return 1;
|
|
}
|
|
|
|
1;
|