|
@@ -33,7 +33,7 @@ class processor extends queue\ILooper
|
|
elseif ($method == 'notify') {
|
|
elseif ($method == 'notify') {
|
|
$channel = $params['channel'];
|
|
$channel = $params['channel'];
|
|
$input = $params['params'];
|
|
$input = $params['params'];
|
|
-
|
|
|
|
|
|
+
|
|
if(empty($channel) || empty($params))
|
|
if(empty($channel) || empty($params))
|
|
return;
|
|
return;
|
|
$this->mProxy->notify($channel,$input);
|
|
$this->mProxy->notify($channel,$input);
|