This document is for Kombu's development version, which can be
significantly different from previous releases. Get the stable docs here:
4.1.
SQS Connection - kombu.asynchronous.aws.sqs.connection
Amazon SQS Connection.
-
class
kombu.asynchronous.aws.sqs.connection.
AsyncSQSConnection
(sqs_connection, debug=0, region=None, **kwargs)[source]
Async SQS Connection.
-
add_permission
(queue, label, aws_account_id, action_name, callback=None)[source]
-
change_message_visibility
(queue, receipt_handle, visibility_timeout, callback=None)[source]
-
change_message_visibility_batch
(queue, messages, callback=None)[source]
-
create_queue
(queue_name, visibility_timeout=None, callback=None)[source]
-
delete_message
(queue, receipt_handle, callback=None)[source]
-
delete_message_batch
(queue, messages, callback=None)[source]
-
delete_message_from_handle
(queue, receipt_handle, callback=None)[source]
-
delete_queue
(queue, force_deletion=False, callback=None)[source]
-
get_all_queues
(prefix=u'', callback=None)[source]
-
get_dead_letter_source_queues
(queue, callback=None)[source]
-
get_queue
(queue_name, callback=None)[source]
-
get_queue_attributes
(queue, attribute=u'All', callback=None)[source]
-
get_queue_url
(queue)[source]
-
lookup
(queue_name, callback=None)
-
receive_message
(queue, number_messages=1, visibility_timeout=None, attributes=None, wait_time_seconds=None, callback=None)[source]
-
remove_permission
(queue, label, callback=None)[source]
-
send_message
(queue, message_content, delay_seconds=None, callback=None)[source]
-
send_message_batch
(queue, messages, callback=None)[source]
-
set_queue_attribute
(queue, attribute, value, callback=None)[source]