modify
This commit is contained in:
@@ -8,7 +8,6 @@ use Exception;
|
||||
use Snowflake\Event;
|
||||
use Snowflake\Process\Process;
|
||||
use Snowflake\Snowflake;
|
||||
use Swoole\Coroutine;
|
||||
|
||||
|
||||
/**
|
||||
@@ -34,8 +33,6 @@ class Consumer extends Process
|
||||
|
||||
$crontab = swoole_unserialize($redis->get($value));
|
||||
$redis->del($value);
|
||||
|
||||
var_dump($crontab);
|
||||
if (!is_object($crontab)) {
|
||||
continue;
|
||||
}
|
||||
|
||||
@@ -200,8 +200,8 @@ class Crontab extends BaseObject
|
||||
public function execute(): void
|
||||
{
|
||||
try {
|
||||
$result = call_user_func($this->handler, $this->params, $this->name);
|
||||
var_dump($result);
|
||||
// $result = call_user_func($this->handler, $this->params, $this->name);
|
||||
var_dump(($this->handler)($this->params, $this->name));
|
||||
} catch (\Throwable $throwable) {
|
||||
$this->addError($throwable->getMessage());
|
||||
} finally {
|
||||
|
||||
Reference in New Issue
Block a user