@@ -30,7 +30,7 @@ |
||
| 30 | 30 | ]; |
| 31 | 31 | |
| 32 | 32 | /** |
| 33 | - * @param $class string FQCN of AMQPConnection class to instantiate. |
|
| 33 | + * @param string $class string FQCN of AMQPConnection class to instantiate. |
|
| 34 | 34 | * @param array $parameters |
| 35 | 35 | * @throws InvalidAMQPConnectionClassException |
| 36 | 36 | */ |
@@ -106,7 +106,7 @@ |
||
| 106 | 106 | } |
| 107 | 107 | |
| 108 | 108 | /** |
| 109 | - * @return ConnectionManagerInterface |
|
| 109 | + * @return \PhpAmqpLib\Connection\AMQPStreamConnection |
|
| 110 | 110 | */ |
| 111 | 111 | public function getConnection() |
| 112 | 112 | { |
@@ -29,7 +29,7 @@ |
||
| 29 | 29 | } |
| 30 | 30 | |
| 31 | 31 | /** |
| 32 | - * @param $queue |
|
| 32 | + * @param string $queue |
|
| 33 | 33 | * @param RpcServiceInterface $serviceCallback |
| 34 | 34 | * @param bool|false $passive |
| 35 | 35 | * @param bool|false $durable |