改名
This commit is contained in:
@@ -57,11 +57,12 @@ class Producer extends Component
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* @param string $name
|
||||
* @throws Exception
|
||||
*/
|
||||
public function exists(string $name)
|
||||
/**
|
||||
* @param string $name
|
||||
* @return bool
|
||||
* @throws Exception
|
||||
*/
|
||||
public function exists(string $name): bool
|
||||
{
|
||||
$redis = Snowflake::app()->getRedis();
|
||||
if ($redis->exists('crontab:' . md5($name))) {
|
||||
|
||||
@@ -96,10 +96,7 @@ class Logger extends Component
|
||||
$message = $this->arrayFormat($message);
|
||||
}
|
||||
if (!empty($message)) {
|
||||
if (!is_array($this->logs)) {
|
||||
$this->logs = [];
|
||||
}
|
||||
$this->logs[] = [$method, $message];
|
||||
$this->write($message, $method);
|
||||
}
|
||||
return $message;
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user