diff --git a/kombu/transport/SQS.py b/kombu/transport/SQS.py index 80b1af5b1..514e24a02 100644 --- a/kombu/transport/SQS.py +++ b/kombu/transport/SQS.py @@ -439,7 +439,7 @@ def _put(self, queue, message, **kwargs): c.change_message_visibility( QueueUrl=q_url, ReceiptHandle=message['properties']['delivery_tag'], - VisibilityTimeout=0 + VisibilityTimeout=self.wait_time_seconds ) else: c.send_message(**kwargs) diff --git a/t/unit/transport/test_SQS.py b/t/unit/transport/test_SQS.py index 8a0a7d60a..e5ab82379 100644 --- a/t/unit/transport/test_SQS.py +++ b/t/unit/transport/test_SQS.py @@ -408,7 +408,9 @@ def test_redelivered(self): 'properties': {'delivery_tag': 'test_message_id'} } self.channel._put(self.producer.routing_key, message) - self.sqs_conn_mock.change_message_visibility.assert_called_once() + self.sqs_conn_mock.change_message_visibility.assert_called_once_with( + QueueUrl='https://sqs.us-east-1.amazonaws.com/xxx/unittest', + ReceiptHandle='test_message_id', VisibilityTimeout=10) def test_put_and_get_bulk(self): # With QoS.prefetch_count = 0