@@ -14,12 +14,12 @@ |
||
| 14 | 14 | */ |
| 15 | 15 | protected $swoole; |
| 16 | 16 | |
| 17 | - /** |
|
| 18 | - * Create a new Swoole Async task connector instance. |
|
| 19 | - * |
|
| 20 | - * @param \Swoole\Http\Server $swoole |
|
| 21 | - * @return void |
|
| 22 | - */ |
|
| 17 | + /** |
|
| 18 | + * Create a new Swoole Async task connector instance. |
|
| 19 | + * |
|
| 20 | + * @param \Swoole\Http\Server $swoole |
|
| 21 | + * @return void |
|
| 22 | + */ |
|
| 23 | 23 | public function __construct($swoole) |
| 24 | 24 | { |
| 25 | 25 | $this->swoole = $swoole; |
@@ -67,12 +67,12 @@ discard block |
||
| 67 | 67 | }); |
| 68 | 68 | } |
| 69 | 69 | |
| 70 | - /** |
|
| 71 | - * Create a payload for an object-based queue handler. |
|
| 72 | - * |
|
| 73 | - * @param mixed $job |
|
| 74 | - * @return array |
|
| 75 | - */ |
|
| 70 | + /** |
|
| 71 | + * Create a payload for an object-based queue handler. |
|
| 72 | + * |
|
| 73 | + * @param mixed $job |
|
| 74 | + * @return array |
|
| 75 | + */ |
|
| 76 | 76 | protected function createObjectPayload($job) |
| 77 | 77 | { |
| 78 | 78 | return [ |
@@ -87,14 +87,14 @@ discard block |
||
| 87 | 87 | ]; |
| 88 | 88 | } |
| 89 | 89 | |
| 90 | - /** |
|
| 91 | - * Create a typical, string based queue payload array. |
|
| 92 | - * |
|
| 93 | - * @param string $job |
|
| 94 | - * @param mixed $data |
|
| 95 | - * |
|
| 96 | - * @throws Expcetion |
|
| 97 | - */ |
|
| 90 | + /** |
|
| 91 | + * Create a typical, string based queue payload array. |
|
| 92 | + * |
|
| 93 | + * @param string $job |
|
| 94 | + * @param mixed $data |
|
| 95 | + * |
|
| 96 | + * @throws Expcetion |
|
| 97 | + */ |
|
| 98 | 98 | protected function createStringPayload($job, $data) |
| 99 | 99 | { |
| 100 | 100 | throw new Exception("Unsupported empty data"); |