@@ -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 |