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