@@ -188,7 +188,7 @@ discard block |
||
| 188 | 188 | * Internal wrapper method, mainly for testing. |
| 189 | 189 | * |
| 190 | 190 | * @param resource $stream |
| 191 | - * @param $len |
|
| 191 | + * @param integer|null $len |
|
| 192 | 192 | * |
| 193 | 193 | * @return string |
| 194 | 194 | */ |
@@ -214,7 +214,7 @@ discard block |
||
| 214 | 214 | /** |
| 215 | 215 | * Internal wrapper method, mainly for testing. |
| 216 | 216 | * |
| 217 | - * @param $stream |
|
| 217 | + * @param resource $stream |
|
| 218 | 218 | * |
| 219 | 219 | * @return array |
| 220 | 220 | */ |
@@ -17,8 +17,8 @@ |
||
| 17 | 17 | |
| 18 | 18 | /** |
| 19 | 19 | * @param string[] $queues |
| 20 | - * @param $count |
|
| 21 | - * @param $timeout |
|
| 20 | + * @param integer $count |
|
| 21 | + * @param integer $timeout |
|
| 22 | 22 | */ |
| 23 | 23 | public function __construct(array $queues, $count, $timeout) |
| 24 | 24 | { |
@@ -114,7 +114,7 @@ |
||
| 114 | 114 | * |
| 115 | 115 | * The list is ordered descending by the frequency of Jobs. |
| 116 | 116 | * |
| 117 | - * @return float[] |
|
| 117 | + * @return string |
|
| 118 | 118 | */ |
| 119 | 119 | public function nodes($queue) |
| 120 | 120 | { |
@@ -36,6 +36,7 @@ |
||
| 36 | 36 | * If the node is not known, no messages have been retrieved from it, so 0. will be returned. |
| 37 | 37 | * |
| 38 | 38 | * @param $nodeId |
| 39 | + * @param string $queue |
|
| 39 | 40 | * |
| 40 | 41 | * @return float |
| 41 | 42 | */ |
@@ -1,10 +1,10 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Created by PhpStorm. |
|
| 4 | - * User: jan.kohlhof |
|
| 5 | - * Date: 22.02.16 |
|
| 6 | - * Time: 00:52 |
|
| 7 | - */ |
|
| 3 | + * Created by PhpStorm. |
|
| 4 | + * User: jan.kohlhof |
|
| 5 | + * Date: 22.02.16 |
|
| 6 | + * Time: 00:52 |
|
| 7 | + */ |
|
| 8 | 8 | |
| 9 | 9 | namespace Phloppy\Subscriber; |
| 10 | 10 | |