@@ -99,6 +99,9 @@ |
||
| 99 | 99 | } |
| 100 | 100 | } |
| 101 | 101 | |
| 102 | + /** |
|
| 103 | + * @param string $queueName |
|
| 104 | + */ |
|
| 102 | 105 | protected function doPopMessage($queueName) |
| 103 | 106 | { |
| 104 | 107 | $query = 'SELECT id, message FROM bernard_messages |
@@ -184,6 +184,7 @@ |
||
| 184 | 184 | /** |
| 185 | 185 | * Generates a uuid. |
| 186 | 186 | * |
| 187 | + * @param string $queueName |
|
| 187 | 188 | * @return string |
| 188 | 189 | */ |
| 189 | 190 | private function getJobFilename($queueName) |
@@ -116,7 +116,7 @@ |
||
| 116 | 116 | * @param array $data |
| 117 | 117 | * @param string $type |
| 118 | 118 | * @param Context $context |
| 119 | - * @return Envelope |
|
| 119 | + * @return DefaultMessage |
|
| 120 | 120 | */ |
| 121 | 121 | public function deserializeDefaultMessage(AbstractVisitor $visitor, array $data, $type, Context $context) |
| 122 | 122 | { |
@@ -12,7 +12,7 @@ |
||
| 12 | 12 | protected $redis; |
| 13 | 13 | |
| 14 | 14 | /** |
| 15 | - * @param Redis $redis |
|
| 15 | + * @param \Redis $redis |
|
| 16 | 16 | */ |
| 17 | 17 | public function __construct(\Redis $redis) |
| 18 | 18 | { |