add delete functionality

src/Adapter/AdapterInterface.php

@@ -45,5 +45,13 @@ public function dequeue(MessageFactoryInterface $factory, $limit);
      */
     public function enqueue(array $messages);
 
+    /**
+     * @return void
+     */
     public function purge();
+
+    /**
+     * @return void
+     */
+    public function delete();
 }

src/Adapter/ArrayAdapter.php

@@ -79,6 +79,14 @@ public function purge()
         $this->queue = [];
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function delete()
+    {
+        $this->purge();
+    }
+
     /**
      * @param MessageInterface $message
      */

src/Adapter/SqsAdapter.php

@@ -198,6 +198,14 @@ public function purge()
         $this->client->purgeQueue(['QueueUrl' => $this->getQueueUrl()]);
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function delete()
+    {
+        $this->client->deleteQueue(['QueueUrl' => $this->getQueueUrl()]);
+    }
+
     /**
      * @param MessageInterface[] $messages
      *

src/Client.php

@@ -92,6 +92,14 @@ public function purge()
         return $this->adapter->purge();
     }
 
+    /**
+     * {@inheritdoc}
+     */
+    public function delete()
+    {
+        $this->adapter->delete();
+    }
+
     /**
      * @return callable
      */

src/ProducerInterface.php

@@ -10,7 +10,7 @@
  *
  * @license https://github.com/graze/queue/blob/master/LICENSE MIT
  *
- * @link https://github.com/graze/queue
+ * @link    https://github.com/graze/queue
  */
 
 namespace Graze\Queue;
@@ -24,9 +24,17 @@ interface ProducerInterface
     public function create($body, array $options = []);
 
     /**
-     * @param array $message
+     * @param array $messages
      */
     public function send(array $messages);
 
+    /**
+     * @return void
+     */
     public function purge();
+
+    /**
+     * @return void
+     */
+    public function delete();
 }

tests/integration/ArrayIntegrationTest.php

@@ -94,4 +94,16 @@ public function testPurge()
 
         assertThat($msgs, is(emptyArray()));
     }
+
+    public function testDelete()
+    {
+        $this->client->delete();
+
+        $msgs = [];
+        $this->client->receive(function ($msg) use (&$msgs) {
+            $msgs[] = $msg;
+        }, null);
+
+        assertThat($msgs, is(emptyArray()));
+    }
 }

tests/integration/SqsIntegrationTest.php

@@ -232,4 +232,16 @@ public function testPurge()
 
         assertThat($msgs, is(emptyArray()));
     }
+
+    public function testDelete()
+    {
+        $url = $this->stubCreateQueue();
+
+        $deleteModel = m::mock('Aws\ResultInterface');
+        $this->sqsClient->shouldReceive('deleteQueue')->once()->with([
+            'QueueUrl' => $url,
+        ])->andReturn($deleteModel);
+
+        $this->client->delete();
+    }
 }

tests/unit/Adapter/ArrayAdapterTest.php

@@ -121,4 +121,17 @@ public function testPurge()
 
         assertThat(iterator_to_array($iterator), is(emptyArray()));
     }
+
+    public function testDelete()
+    {
+        $iterator = $this->adapter->dequeue($this->factory, 10);
+
+        assertThat(iterator_to_array($iterator), is(nonEmptyArray()));
+
+        $this->adapter->delete();
+
+        $iterator = $this->adapter->dequeue($this->factory, 10);
+
+        assertThat(iterator_to_array($iterator), is(emptyArray()));
+    }
 }

tests/unit/Adapter/SqsAdapterTest.php

@@ -234,4 +234,16 @@ public function testPurge()
 
         assertThat($adapter->purge(), is(nullValue()));
     }
+
+    public function testDelete()
+    {
+        $adapter = new SqsAdapter($this->client, 'foo');
+        $url = $this->stubCreateQueue('foo');
+
+        $this->client->shouldReceive('deleteQueue')->once()->with([
+            'QueueUrl' => $url,
+        ])->andReturn($this->model);
+
+        assertThat($adapter->delete(), is(nullValue()));
+    }
 }