3 use base qw(Gearman::Driver::Worker);
7 use Data::Dump qw(dump);
11 with 'APKPM::Gearman';
16 my ( $self, $orig, $job_name ) = @_;
17 warn "# process_name $orig $job_name\n";
18 return "$orig ($job_name)";
21 sub poll : Job : MinProcesses(1) : MaxProcesses(5) : Encode(e_json) : Decode(d_json) {
22 my ( $self, $job, $workload ) = @_;
23 warn "# poll $job ", dump($workload);