@@ -154,7 +154,7 @@ discard block |
||
| 154 | 154 | * @param string $queue |
| 155 | 155 | * @param int $timeout |
| 156 | 156 | * |
| 157 | - * @return mixed|null|Queue |
|
| 157 | + * @return Message|null |
|
| 158 | 158 | */ |
| 159 | 159 | public function pop($queue, $timeout = 0) |
| 160 | 160 | { |
@@ -171,7 +171,7 @@ discard block |
||
| 171 | 171 | * @param string $queue |
| 172 | 172 | * @param int $timeout |
| 173 | 173 | * |
| 174 | - * @return MessageInterface|null |
|
| 174 | + * @return null|Message |
|
| 175 | 175 | */ |
| 176 | 176 | public function reserve($queue, $timeout = 0) |
| 177 | 177 | { |
@@ -222,7 +222,7 @@ discard block |
||
| 222 | 222 | /** |
| 223 | 223 | * @param string|null $token |
| 224 | 224 | * |
| 225 | - * @return null|MessageInterface |
|
| 225 | + * @return null|Message |
|
| 226 | 226 | */ |
| 227 | 227 | protected function restoreMessage($token) |
| 228 | 228 | { |
@@ -260,7 +260,7 @@ discard block |
||
| 260 | 260 | } |
| 261 | 261 | |
| 262 | 262 | /** |
| 263 | - * @param string|MessageInterface $mixed |
|
| 263 | + * @param Message $mixed |
|
| 264 | 264 | * |
| 265 | 265 | * @return $this |
| 266 | 266 | * @throws QueueException |
@@ -582,7 +582,7 @@ discard block |
||
| 582 | 582 | } |
| 583 | 583 | |
| 584 | 584 | /** |
| 585 | - * @param int|\DateTime $mixed |
|
| 585 | + * @param integer $mixed |
|
| 586 | 586 | * |
| 587 | 587 | * @return int |
| 588 | 588 | */ |