38 lines
968 B
Perl
38 lines
968 B
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');
|
||
|
|
$app->plugin('Minion' => $app->config->{minion} );
|
||
|
|
|
||
|
|
my $job_namespace = __PACKAGE__ . '::Job';
|
||
|
|
my @modules = find_modules $job_namespace;
|
||
|
|
for my $package ( @modules ) {
|
||
|
|
my ( $job ) = $package =~ /${job_namespace}::(.*)$/;
|
||
|
|
$app->log->debug( $package );
|
||
|
|
$app->log->debug( $job );
|
||
|
|
load_class $package;
|
||
|
|
$app->minion->add_task(
|
||
|
|
$job => 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');
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
1;
|