|
@@ -252,6 +252,8 @@ class GearmanClient extends AbstractGearmanService
|
|
|
$result = $gearmanClient->$method($worker['job']['realCallableName'], $params, $unique);
|
|
|
$this->returnCode = $gearmanClient->returnCode();
|
|
|
|
|
|
+ $this->gearmanClient = null;
|
|
|
+
|
|
|
return $result;
|
|
|
}
|
|
|
|
|
@@ -449,6 +451,8 @@ class GearmanClient extends AbstractGearmanService
|
|
|
|
|
|
$jobStatus = new JobStatus($statusData);
|
|
|
|
|
|
+ $this->gearmanClient = null;
|
|
|
+
|
|
|
return $jobStatus;
|
|
|
}
|
|
|
|
|
@@ -686,6 +690,8 @@ class GearmanClient extends AbstractGearmanService
|
|
|
|
|
|
$this->initTaskStructure();
|
|
|
|
|
|
+ $this->gearmanClient = null;
|
|
|
+
|
|
|
return $gearmanClient->runTasks();
|
|
|
}
|
|
|
}
|