Add SQS purge_queue action. Closes #349.

This commit is contained in:
Steve Pulec 2015-05-29 23:21:14 -04:00
commit 6b44e41249
3 changed files with 32 additions and 0 deletions

View file

@ -428,3 +428,16 @@ def test_change_message_visibility_on_visible_message():
queue.count().should.equal(1)
original_message.change_visibility.when.called_with(100).should.throw(SQSError)
@mock_sqs
def test_purge_action():
conn = boto.sqs.connect_to_region("us-east-1")
queue = conn.create_queue('new-queue')
queue.write(queue.new_message('this is another test message'))
queue.count().should.equal(1)
queue.purge()
queue.count().should.equal(0)