#!/usr/bin/perl
package MyWorker;
use base qw( TheSchwartz::Worker );
sub work {
my $class = shift;
my $job = shift;
my $arg = $job->arg;
warn $arg->{msg};
$job->completed;
}
package main;
use TheSchwartz;
my $dbname = shift @ARGV or die "dbname required";
my $client = TheSchwartz->new(databases => [ { dsn => "dbi:mysql:$dbname", user => 'root' } ]);
$client->set_prioritize(1);
$client->can_do('MyWorker');
$client->work_once;
1;