From 0f16741d08e16cbed70db612dae364496fecd448 Mon Sep 17 00:00:00 2001 From: Dobrica Pavlinusic Date: Tue, 13 Dec 2011 00:21:34 +0100 Subject: [PATCH] ported back to Gearman::Client --- lib/CloudStore/Gearman.pm | 14 ++++++-------- 1 file changed, 6 insertions(+), 8 deletions(-) diff --git a/lib/CloudStore/Gearman.pm b/lib/CloudStore/Gearman.pm index 6e2cd90..9b74a55 100644 --- a/lib/CloudStore/Gearman.pm +++ b/lib/CloudStore/Gearman.pm @@ -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; -- 2.20.1