| @@ 346-356 (lines=11) @@ | ||
| 343 | assertThat(iterator_to_array($iterator), is(equalTo($this->messages))); |
|
| 344 | } |
|
| 345 | ||
| 346 | public function testPurge() |
|
| 347 | { |
|
| 348 | $adapter = new SqsAdapter($this->client, 'foo'); |
|
| 349 | $url = $this->stubCreateQueue('foo'); |
|
| 350 | ||
| 351 | $this->client->shouldReceive('purgeQueue')->once()->with([ |
|
| 352 | 'QueueUrl' => $url, |
|
| 353 | ])->andReturn($this->model); |
|
| 354 | ||
| 355 | assertThat($adapter->purge(), is(nullValue())); |
|
| 356 | } |
|
| 357 | ||
| 358 | public function testDelete() |
|
| 359 | { |
|
| @@ 358-368 (lines=11) @@ | ||
| 355 | assertThat($adapter->purge(), is(nullValue())); |
|
| 356 | } |
|
| 357 | ||
| 358 | public function testDelete() |
|
| 359 | { |
|
| 360 | $adapter = new SqsAdapter($this->client, 'foo'); |
|
| 361 | $url = $this->stubCreateQueue('foo'); |
|
| 362 | ||
| 363 | $this->client->shouldReceive('deleteQueue')->once()->with([ |
|
| 364 | 'QueueUrl' => $url, |
|
| 365 | ])->andReturn($this->model); |
|
| 366 | ||
| 367 | assertThat($adapter->delete(), is(nullValue())); |
|
| 368 | } |
|
| 369 | } |
|
| 370 | ||