This commit is contained in:
Clint Ecker 2014-06-22 13:34:32 -05:00
parent 67933574b9
commit a9ef2eaaf4
2 changed files with 4 additions and 4 deletions

View File

@ -43,9 +43,9 @@ class Message(object):
if delay_seconds: if delay_seconds:
self.delay(delay_seconds=delay_seconds) self.delay(delay_seconds=delay_seconds)
def mark_recieved(self, visibility_timeout=None): def mark_received(self, visibility_timeout=None):
""" """
When a message is received we will set the first recieve timestamp, When a message is received we will set the first receive timestamp,
tap the ``approximate_receive_count`` and the ``visible_at`` time. tap the ``approximate_receive_count`` and the ``visible_at`` time.
""" """
if visibility_timeout: if visibility_timeout:
@ -225,7 +225,7 @@ class SQSBackend(BaseBackend):
result = [] result = []
# queue.messages only contains visible messages # queue.messages only contains visible messages
for message in queue.messages: for message in queue.messages:
message.mark_recieved( message.mark_received(
visibility_timeout=queue.visibility_timeout visibility_timeout=queue.visibility_timeout
) )
result.append(message) result.append(message)

View File

@ -104,7 +104,7 @@ def test_send_message_with_delay():
@mock_sqs @mock_sqs
def test_message_becomes_inflight_when_recieved(): def test_message_becomes_inflight_when_received():
conn = boto.connect_sqs('the_key', 'the_secret') conn = boto.connect_sqs('the_key', 'the_secret')
queue = conn.create_queue("test-queue", visibility_timeout=2) queue = conn.create_queue("test-queue", visibility_timeout=2)