@@ -48,7 +48,6 @@ |
||
| 48 | 48 | } |
| 49 | 49 | |
| 50 | 50 | /** |
| 51 | - * @param string $queueName NB: complete queue name as used by SQS |
|
| 52 | 51 | * @return Producer |
| 53 | 52 | * @todo test that we can successfully send messages to 2 queues using the same SqsClient |
| 54 | 53 | */ |
@@ -86,6 +86,9 @@ |
||
| 86 | 86 | $this->connections[$connectionId] = $params; |
| 87 | 87 | } |
| 88 | 88 | |
| 89 | + /** |
|
| 90 | + * @param string $connectionId |
|
| 91 | + */ |
|
| 89 | 92 | protected function getConnectionConfig($connectionId) |
| 90 | 93 | { |
| 91 | 94 | if (!isset($this->connections[$connectionId])) { |