kombu.transport.SQS

Amazon SQS transport.

copyright:

3. 2010 - 2012 by Ask Solem

license:

BSD, see LICENSE for more details.

Transport

class kombu.transport.SQS.Transport(client, **kwargs)

class Channel(*args, **kwargs)

class Table(connection=None, name=None)

Amazon SimpleDB domain describing the message routing table.

create_binding(queue)

Get binding item for queue.

Creates the item if it doesn’t exist.

exchange_delete(exchange)

Delete all routes for exchange.

get_exchanges()

get_item(item_name)

Uses consistent_read by default.

get_queue(queue)

Get binding for queue.

queue_bind(exchange, routing_key, pattern, queue)

queue_delete(queue)

delete queue by name.

routes_for(exchange)

Iterator giving all routes for an exchange.

select(query='', next_token=None, consistent_read=True, max_items=None)

Uses consistent_read by default.

Transport.Channel.basic_ack(delivery_tag)

Transport.Channel.basic_cancel(consumer_tag)

Transport.Channel.basic_consume(queue, no_ack, *args, **kwargs)

Transport.Channel.close()

Transport.Channel.conninfo

Transport.Channel.default_region = 'us-east-1'

Transport.Channel.domain_format = 'kombu%(vhost)s'

Transport.Channel.entity_name(name, table={33: 95, 34: 95, 35: 95, 36: 95, 37: 95, 38: 95, 39: 95, 40: 95, 41: 95, 42: 95, 43: 95, 44: 95, 46: 45, 47: 95, 58: 95, 59: 95, 60: 95, 61: 95, 62: 95, 63: 95, 64: 95, 91: 95, 92: 95, 93: 95, 94: 95, 96: 95, 123: 95, 124: 95, 125: 95, 126: 95})

Format AMQP queue name into a legal SQS queue name.

Transport.Channel.exchange_delete(exchange, **kwargs)

Delete exchange by name.

Transport.Channel.get_exchanges()

Transport.Channel.get_table(exchange)

Get routing table.

Retrieved from SDB if supports_fanout.

Transport.Channel.queue_name_prefix

Transport.Channel.region

Transport.Channel.sdb

Transport.Channel.sqs

Transport.Channel.supports_fanout

Transport.Channel.table

Transport.Channel.transport_options

Transport.Channel.visibility_timeout

Transport.channel_errors = (<class 'boto.exception.SQSDecodeError'>, <class 'kombu.exceptions.StdChannelError'>)

Transport.connection_errors = (<class 'boto.exception.SQSError'>, <class 'socket.error'>)

Transport.default_port = None

Transport.polling_interval = 1

Channel

class kombu.transport.SQS.Channel(*args, **kwargs)

class Table(connection=None, name=None)

Amazon SimpleDB domain describing the message routing table.

create_binding(queue)

Get binding item for queue.

Creates the item if it doesn’t exist.

exchange_delete(exchange)

Delete all routes for exchange.

get_exchanges()

get_item(item_name)

Uses consistent_read by default.

get_queue(queue)

Get binding for queue.

queue_bind(exchange, routing_key, pattern, queue)

queue_delete(queue)

delete queue by name.

routes_for(exchange)

Iterator giving all routes for an exchange.

select(query='', next_token=None, consistent_read=True, max_items=None)

Uses consistent_read by default.

Channel.basic_ack(delivery_tag)

Channel.basic_cancel(consumer_tag)

Channel.basic_consume(queue, no_ack, *args, **kwargs)

Channel.close()

Channel.conninfo

Channel.default_region = 'us-east-1'

Channel.domain_format = 'kombu%(vhost)s'

Channel.entity_name(name, table={33: 95, 34: 95, 35: 95, 36: 95, 37: 95, 38: 95, 39: 95, 40: 95, 41: 95, 42: 95, 43: 95, 44: 95, 46: 45, 47: 95, 58: 95, 59: 95, 60: 95, 61: 95, 62: 95, 63: 95, 64: 95, 91: 95, 92: 95, 93: 95, 94: 95, 96: 95, 123: 95, 124: 95, 125: 95, 126: 95})

Format AMQP queue name into a legal SQS queue name.

Channel.exchange_delete(exchange, **kwargs)

Delete exchange by name.

Channel.get_exchanges()

Channel.get_table(exchange)

Get routing table.

Retrieved from SDB if supports_fanout.

Channel.queue_name_prefix

Channel.region

Channel.sdb

Channel.sqs

Channel.supports_fanout

Channel.table

Channel.transport_options

Channel.visibility_timeout