@@ -19,6 +19,9 @@ discard block |
||
| 19 | 19 | private $correlationId; |
| 20 | 20 | private $callbackQueue; |
| 21 | 21 | |
| 22 | + /** |
|
| 23 | + * @param string $queueName |
|
| 24 | + */ |
|
| 22 | 25 | public function __construct($queueName, ConnectionManager $manager, $fromName = '') |
| 23 | 26 | { |
| 24 | 27 | $this->queueName = $queueName; |
@@ -54,7 +57,7 @@ discard block |
||
| 54 | 57 | } |
| 55 | 58 | |
| 56 | 59 | /** |
| 57 | - * @param $data |
|
| 60 | + * @param string $data |
|
| 58 | 61 | * @param int $expire |
| 59 | 62 | * @param int $priority |
| 60 | 63 | * @throws QueueNotFoundException |
@@ -140,7 +143,7 @@ discard block |
||
| 140 | 143 | /** |
| 141 | 144 | * @todo unecessary method set, its only exists to run tests whitout stay jailed in infinite while waiting response. |
| 142 | 145 | * |
| 143 | - * @param $content |
|
| 146 | + * @param string $content |
|
| 144 | 147 | */ |
| 145 | 148 | public function setResponse($content) |
| 146 | 149 | { |
@@ -170,7 +173,7 @@ discard block |
||
| 170 | 173 | } |
| 171 | 174 | |
| 172 | 175 | /** |
| 173 | - * @return string |
|
| 176 | + * @return boolean |
|
| 174 | 177 | */ |
| 175 | 178 | public function getExchange() |
| 176 | 179 | { |
@@ -178,7 +181,7 @@ discard block |
||
| 178 | 181 | } |
| 179 | 182 | |
| 180 | 183 | /** |
| 181 | - * @return string |
|
| 184 | + * @return boolean |
|
| 182 | 185 | */ |
| 183 | 186 | public function getExchangeType() |
| 184 | 187 | { |