@@ -24,6 +24,10 @@ discard block |
||
| 24 | 24 | private $correlationId; |
| 25 | 25 | private $callbackQueue; |
| 26 | 26 | |
| 27 | + /** |
|
| 28 | + * @param string $queueName |
|
| 29 | + * @param string $fromName |
|
| 30 | + */ |
|
| 27 | 31 | public function __construct($queueName, ConnectionManager $manager, $fromName, $connectionName = 'default') |
| 28 | 32 | { |
| 29 | 33 | $this->connectionName = $connectionName; |
@@ -74,7 +78,7 @@ discard block |
||
| 74 | 78 | } |
| 75 | 79 | |
| 76 | 80 | /** |
| 77 | - * @param $data |
|
| 81 | + * @param string $data |
|
| 78 | 82 | * @param int $expire |
| 79 | 83 | * @param int $priority |
| 80 | 84 | * @throws QueueNotFoundException |
@@ -151,7 +155,7 @@ discard block |
||
| 151 | 155 | /** |
| 152 | 156 | * @todo unecessary method set, its only exists to run tests whitout stay jailed in infinite while waiting response. |
| 153 | 157 | * |
| 154 | - * @param $content |
|
| 158 | + * @param string $content |
|
| 155 | 159 | */ |
| 156 | 160 | public function setResponse($content) |
| 157 | 161 | { |
@@ -181,7 +185,7 @@ discard block |
||
| 181 | 185 | } |
| 182 | 186 | |
| 183 | 187 | /** |
| 184 | - * @return string |
|
| 188 | + * @return boolean |
|
| 185 | 189 | */ |
| 186 | 190 | public function getExchange() |
| 187 | 191 | { |
@@ -189,7 +193,7 @@ discard block |
||
| 189 | 193 | } |
| 190 | 194 | |
| 191 | 195 | /** |
| 192 | - * @return string |
|
| 196 | + * @return boolean |
|
| 193 | 197 | */ |
| 194 | 198 | public function getExchangeType() |
| 195 | 199 | { |
@@ -206,7 +210,7 @@ discard block |
||
| 206 | 210 | |
| 207 | 211 | /** |
| 208 | 212 | * @param CmobiAMQPConnectionInterface $connection |
| 209 | - * @param $expire |
|
| 213 | + * @param integer $expire |
|
| 210 | 214 | * @param $corralationId |
| 211 | 215 | * @return CmobiAMQPConnectionInterface |
| 212 | 216 | */ |