|
21 | 21 | use AsyncAws\Ses\SesClient; |
22 | 22 | use AsyncAws\Sns\SnsClient; |
23 | 23 | use AsyncAws\Sqs\SqsClient; |
| 24 | +use AsyncAws\Ssm\SsmClient; |
24 | 25 | use Psr\Log\LoggerInterface; |
25 | 26 | use Psr\Log\NullLogger; |
26 | 27 | use Symfony\Component\HttpClient\HttpClient; |
@@ -158,27 +159,40 @@ public function sns(): SnsClient |
158 | 159 | return $this->serviceCache[__METHOD__]; |
159 | 160 | } |
160 | 161 |
|
161 | | - public function sts(): StsClient |
| 162 | + public function sqs(): SqsClient |
162 | 163 | { |
163 | | - if (!class_exists(StsClient::class)) { |
164 | | - throw MissingDependency::create('async-aws/core', 'STS'); |
| 164 | + if (!class_exists(SqsClient::class)) { |
| 165 | + throw MissingDependency::create('async-aws/sqs', 'SQS'); |
165 | 166 | } |
166 | 167 |
|
167 | 168 | if (!isset($this->serviceCache[__METHOD__])) { |
168 | | - $this->serviceCache[__METHOD__] = new StsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger); |
| 169 | + $this->serviceCache[__METHOD__] = new SqsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger); |
169 | 170 | } |
170 | 171 |
|
171 | 172 | return $this->serviceCache[__METHOD__]; |
172 | 173 | } |
173 | 174 |
|
174 | | - public function sqs(): SqsClient |
| 175 | + public function ssm(): SsmClient |
175 | 176 | { |
176 | | - if (!class_exists(SqsClient::class)) { |
177 | | - throw MissingDependency::create('async-aws/sqs', 'SQS'); |
| 177 | + if (!class_exists(SsmClient::class)) { |
| 178 | + throw MissingDependency::create('async-aws/ssm', 'SSM'); |
178 | 179 | } |
179 | 180 |
|
180 | 181 | if (!isset($this->serviceCache[__METHOD__])) { |
181 | | - $this->serviceCache[__METHOD__] = new SqsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger); |
| 182 | + $this->serviceCache[__METHOD__] = new SsmClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger); |
| 183 | + } |
| 184 | + |
| 185 | + return $this->serviceCache[__METHOD__]; |
| 186 | + } |
| 187 | + |
| 188 | + public function sts(): StsClient |
| 189 | + { |
| 190 | + if (!class_exists(StsClient::class)) { |
| 191 | + throw MissingDependency::create('async-aws/core', 'STS'); |
| 192 | + } |
| 193 | + |
| 194 | + if (!isset($this->serviceCache[__METHOD__])) { |
| 195 | + $this->serviceCache[__METHOD__] = new StsClient($this->configuration, $this->credentialProvider, $this->httpClient, $this->logger); |
182 | 196 | } |
183 | 197 |
|
184 | 198 | return $this->serviceCache[__METHOD__]; |
|
0 commit comments