YAPC::Asia Qudo::Plugin::Logger&Qudo::Hook::Notify demo script

gistfile1.pl

#!/usr/bin/perl 

use strict;
use warnings;

use Qudo;
my $qudo = Qudo->new(
    driver_class => 'Skinny',
    databases => [+{
        dsn      => 'dbi:mysql:qudo',
        username => 'root',
        password => '',
    }],
);

$qudo->enqueue("MyApp::Worker::Abort", { arg => 'arg' });

gistfile2.pl

#!/usr/bin/perl 

use strict;
use warnings;
use Qudo;
use MyApp::Worker::Abort;

my $qudo = Qudo->new(
    driver_class => 'Skinny',
    databases => [+{
        dsn      => 'dbi:mysql:qudo',
        username => 'root',
        password => '',
    }],
    manager_abilities => [qw/MyApp::Worker::Abort /],
);

$qudo->manager->register_hooks(qw/Qudo::Hook::Notify::Abort/);
$qudo->manager->register_plugins(
    +{
        name => 'Qudo::Plugin::Logger',
        option => +{
            dispatchers => ['screen'],
            screen => {
                class     => 'Log::Dispatch::Screen',
                min_level => 'debug',
                stderr    => 0,
            },
        },
    }
);
$qudo->manager->work_once;

package MyApp::Worker::Abort;

use strict;
use warnings;
use base qw/Qudo::Worker/;

sub work {
    my ($self , $job ) = @_;
    $job->abort();
}

1;