cleanup Poll::prefix

diff --git a/gearman_driver.pl b/gearman_driver.pl
index 268519b..492ea6a 100755 (executable)
--- a/gearman_driver.pl
+++ b/gearman_driver.pl
@@ -15,7 +15,11 @@ my $driver = Gearman::Driver->new(
        server     => $ENV{GEARMAN} || 'localhost:4730',
        interval   => 3,
        job_runtime_attributes => {
-               'APKPM::Poll::ip_username' => {
+               'APKPM::Poll::poll_prefix' => {
+                       max_processes => 1,
+                       min_processes => 1,
+               },
+               'APKPM::Poll::poll_ip_username' => {
                        max_processes => 100,
                        min_processes => 1,
                },

diff --git a/lib/APKPM/Poll.pm b/lib/APKPM/Poll.pm
index 20372e3..ab30f71 100644 (file)
--- a/lib/APKPM/Poll.pm
+++ b/lib/APKPM/Poll.pm
@@ -9,9 +9,9 @@ use Redis;
 with 'APKPM::Gearman::Client';
 with 'APKPM::Gearman';
 
-sub prefix { 'poll_' }
+sub prefix { '' }
 
-sub by_prefix : Job : Encode(e_json) {
+sub poll_prefix : Job : Encode(e_json) {
        my ( $self, $job, $workload ) = @_;
 
        my $redis = Redis->new;
@@ -57,7 +57,7 @@ sub by_prefix : Job : Encode(e_json) {
        return { ldap => $ip_username, results => $results, poll => $poll };
 }
 
-sub ip_username : Job : Decode(d_array) : Encode(e_json) {
+sub poll_ip_username : Job : Decode(d_array) : Encode(e_json) {
        my ( $self, $job, $workload ) = @_;
 
        my ( $ip, $username ) = @$workload;

diff --git a/t/Poll.t b/t/Poll.t
index 86f55a0..be73538 100755 (executable)
--- a/t/Poll.t
+++ b/t/Poll.t
@@ -11,8 +11,8 @@ use_ok 'APKPM::Poll';
 
 ok my $o = APKPM::Poll->new( server => 'localhost:4730' ), 'new';
 
-ok my $r = $o->by_prefix( 'job', 'aa' ), 'by_prefix';
+ok my $r = $o->poll_prefix( 'job', 'aa' ), 'poll_prefix';
 diag dump($r);
 
-ok my $r = $o->ip_username( 'job', [ '127.0.0.1', 'nobody' ] ), 'ip_username';
+ok my $r = $o->poll_ip_username( 'job', [ '127.0.0.1', 'nobody' ] ), 'poll_ip_username';
 diag dump($r);