lib/APKPM.pm

   1 package APKPM;
   2
   3 use base qw(Gearman::Driver::Worker);
   4 use Moose;
   5 use Time::HiRes;
   6 use JSON::XS;
   7 use Data::Dump qw(dump);
   8
   9 our $VERSION = '0.00';
  10
  11 with 'APKPM::Gearman';
  12
  13 sub prefix { '' }
  14
  15 sub process_name {
  16         my ( $self, $orig, $job_name ) = @_;
  17         warn "# process_name $orig $job_name\n";
  18         return "$orig ($job_name)";
  19 }
  20
  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);
  24 }
  25
  26 1;