@@ 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 |