ported back to Gearman::Client
authorDobrica Pavlinusic <dpavlin@rsync1.maxxo.com>
Mon, 12 Dec 2011 23:21:34 +0000 (00:21 +0100)
committerDobrica Pavlinusic <dpavlin@rsync1.maxxo.com>
Mon, 12 Dec 2011 23:23:27 +0000 (00:23 +0100)
lib/CloudStore/Gearman.pm

index 6e2cd90..9b74a55 100644 (file)
@@ -2,15 +2,13 @@ package CloudStore::Gearman;
 use warnings;
 use strict;
 
-use Gearman::XS qw(:constants);
-use Gearman::XS::Client;
-
 use Gearman::Client;
+
 use Data::Dump qw(dump);
 
 sub gearman {
-       my $gearman = Gearman::XS::Client->new;
-       $gearman->add_server('127.0.0.1' => 4730);
+       my $gearman = Gearman::Client->new;
+       $gearman->job_servers('127.0.0.1:4730');
        return $gearman;
 }
 
@@ -20,9 +18,9 @@ sub gearman_do {
        my $body = join(' ', @_) . "\n";
        warn "## gearman_do $func [$body]\n";
 
-       my ($ret,$result) = $self->gearman->do( $func => $body );
-       warn "##>> ",dump($ret, $result),$/;
-       return $result;
+       my $result = $self->gearman->do_task( $func => $body );
+       warn "##>> ",dump($result),$/;
+       return $$result;
 }
 
 1;