Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- # enqueue job:
- use Qudo;
- my $qudo = Qudo->new(
- databases => [+{
- dsn => 'dbi:SQLite:/tmp/qudo.db',
- username => '',
- password => '',
- }],
- manager_abilities => [
- 'Worker::Test',
- {
- module => 'Worker::Test2',
- hooks => [qw/Qudo::Hook::Serialize::JSON/],
- },
- ],
- );
- $qudo->enqueue("Worker::Test", { arg => 'arg', uniqkey => 'uniqkey'});
- $qudo->enqueue("Worker::Test2", { arg => {foo => 'bar'}, uniqkey => 'uniqkey'});
- # do work:
- use Qudo;
- my $qudo2 = Qudo->new(
- databases => [+{
- dsn => 'dbi:SQLite:/tmp/qudo.db',
- username => '',
- password => '',
- }],
- manager_abilities => [
- 'Worker::Test',
- {
- module => 'Worker::Test2',
- hooks => [qw/Worker::Hook::Sample/],
- },
- ],
- );
- $qudo2->work(); # boot manager
- # work work work!
Add Comment
Please, Sign In to add comment