| @@ 372-382 (lines=11) @@ | ||
| 369 | assertThat(iterator_to_array($iterator), is(equalTo($this->messages))); |
|
| 370 | } |
|
| 371 | ||
| 372 | public function testPurge() |
|
| 373 | { |
|
| 374 | $adapter = new SqsAdapter($this->client, 'foo'); |
|
| 375 | $url = $this->stubCreateQueue('foo'); |
|
| 376 | ||
| 377 | $this->client->shouldReceive('purgeQueue')->once()->with([ |
|
| 378 | 'QueueUrl' => $url, |
|
| 379 | ])->andReturn($this->model); |
|
| 380 | ||
| 381 | assertThat($adapter->purge(), is(nullValue())); |
|
| 382 | } |
|
| 383 | ||
| 384 | public function testDelete() |
|
| 385 | { |
|
| @@ 384-394 (lines=11) @@ | ||
| 381 | assertThat($adapter->purge(), is(nullValue())); |
|
| 382 | } |
|
| 383 | ||
| 384 | public function testDelete() |
|
| 385 | { |
|
| 386 | $adapter = new SqsAdapter($this->client, 'foo'); |
|
| 387 | $url = $this->stubCreateQueue('foo'); |
|
| 388 | ||
| 389 | $this->client->shouldReceive('deleteQueue')->once()->with([ |
|
| 390 | 'QueueUrl' => $url, |
|
| 391 | ])->andReturn($this->model); |
|
| 392 | ||
| 393 | assertThat($adapter->delete(), is(nullValue())); |
|
| 394 | } |
|
| 395 | } |
|
| 396 | ||