@@ -242,7 +242,7 @@ discard block |
||
| 242 | 242 | } |
| 243 | 243 | |
| 244 | 244 | /** |
| 245 | - * @param $timeout |
|
| 245 | + * @param integer $timeout |
|
| 246 | 246 | * |
| 247 | 247 | * @throws \Exception |
| 248 | 248 | */ |
@@ -291,7 +291,7 @@ discard block |
||
| 291 | 291 | /** |
| 292 | 292 | * @param AMQPMessage $message |
| 293 | 293 | * |
| 294 | - * @return array |
|
| 294 | + * @return string[] |
|
| 295 | 295 | * |
| 296 | 296 | * @throws \OutOfBoundsException |
| 297 | 297 | */ |
@@ -140,7 +140,7 @@ discard block |
||
| 140 | 140 | } |
| 141 | 141 | |
| 142 | 142 | /** |
| 143 | - * @param array $exchangeInformation |
|
| 143 | + * @param string[] $exchangeInformation |
|
| 144 | 144 | * |
| 145 | 145 | * @throws AssertionFailedException |
| 146 | 146 | */ |
@@ -180,7 +180,7 @@ discard block |
||
| 180 | 180 | } |
| 181 | 181 | |
| 182 | 182 | /** |
| 183 | - * @param array $exchangeInformation |
|
| 183 | + * @param string[] $exchangeInformation |
|
| 184 | 184 | * @param OutputInterface $output |
| 185 | 185 | */ |
| 186 | 186 | private function bindExchange(array $exchangeInformation, OutputInterface $output) |
@@ -207,7 +207,7 @@ discard block |
||
| 207 | 207 | |
| 208 | 208 | /** |
| 209 | 209 | * @param string $exchangeName |
| 210 | - * @param array $queueInformation |
|
| 210 | + * @param string[] $queueInformation |
|
| 211 | 211 | * @param OutputInterface $output |
| 212 | 212 | */ |
| 213 | 213 | private function bindQueue( |
@@ -3,17 +3,17 @@ |
||
| 3 | 3 | namespace Burrow\Daemon; |
| 4 | 4 | |
| 5 | 5 | use Burrow\ConsumeOptions; |
| 6 | +use Burrow\Driver; |
|
| 6 | 7 | use Burrow\Event\DaemonStarted; |
| 7 | 8 | use Burrow\Event\DaemonStopped; |
| 8 | 9 | use Burrow\Event\MessageConsumed; |
| 9 | 10 | use Burrow\Event\MessageReceived; |
| 10 | 11 | use Burrow\Event\NullEmitter; |
| 12 | +use Burrow\Message; |
|
| 13 | +use Burrow\QueueHandler; |
|
| 11 | 14 | use Evaneos\Daemon\Daemon; |
| 12 | 15 | use Evaneos\Daemon\DaemonMonitor; |
| 13 | -use Burrow\Driver; |
|
| 14 | -use Burrow\Message; |
|
| 15 | 16 | use Evaneos\Daemon\Monitor\NullMonitor; |
| 16 | -use Burrow\QueueHandler; |
|
| 17 | 17 | use League\Event\Emitter; |
| 18 | 18 | use League\Event\EmitterInterface; |
| 19 | 19 | use Psr\Log\LoggerAwareInterface; |