@@ -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"); |