kombu.transport.redis

Redis transport.

Transport

class kombu.transport.redis.Transport(*args, **kwargs)[source]
class Channel(*args, **kwargs)
class QoS(*args, **kwargs)
ack(delivery_tag)
append(message, delivery_tag)
pipe_or_acquire(*args, **kwds)
reject(delivery_tag, requeue=False)
restore_at_shutdown = True
restore_by_tag(tag, client=None, leftmost=False)
restore_unacked(client=None)
restore_visible(start=0, num=10, interval=10)
unacked_index_key
unacked_key
unacked_mutex_expire
unacked_mutex_key
visibility_timeout
Transport.Channel.ack_emulation = True
Transport.Channel.active_queues

Set of queues being consumed from (excluding fanout queues).

Transport.Channel.async_pool
Transport.Channel.basic_cancel(consumer_tag)
Transport.Channel.basic_consume(queue, *args, **kwargs)
Transport.Channel.client

Client used to publish messages, BRPOP etc.

Transport.Channel.close()
Transport.Channel.conn_or_acquire(*args, **kwds)
Transport.Channel.fanout_patterns = False
Transport.Channel.fanout_prefix = False
Transport.Channel.from_transport_options = (u'body_encoding', u'deadletter_queue', 'ack_emulation', 'unacked_key', 'unacked_index_key', 'unacked_mutex_key', 'unacked_mutex_expire', 'visibility_timeout', 'unacked_restore_limit', 'fanout_prefix', 'fanout_patterns', 'socket_timeout', 'socket_connect_timeout', 'socket_keepalive', 'socket_keepalive_options', 'queue_order_strategy', 'max_connections', 'priority_steps')
Transport.Channel.get_table(exchange)
Transport.Channel.keyprefix_fanout = '/{db}.'
Transport.Channel.keyprefix_queue = '_kombu.binding.%s'
Transport.Channel.max_connections = 10
Transport.Channel.pool
Transport.Channel.priority(n)
Transport.Channel.priority_steps = [0, 3, 6, 9]
Transport.Channel.sep = '\x06\x16'
Transport.Channel.socket_connect_timeout = None
Transport.Channel.socket_keepalive = None
Transport.Channel.socket_keepalive_options = None
Transport.Channel.socket_timeout = None
Transport.Channel.subclient

Pub/Sub connection used to consume fanout queues.

Transport.Channel.supports_fanout = True
Transport.Channel.unacked_index_key = 'unacked_index'
Transport.Channel.unacked_key = 'unacked'
Transport.Channel.unacked_mutex_expire = 300
Transport.Channel.unacked_mutex_key = 'unacked_mutex'
Transport.Channel.unacked_restore_limit = None
Transport.Channel.visibility_timeout = 3600
Transport.default_port = 6379
Transport.driver_name = 'redis'
Transport.driver_type = 'redis'
Transport.driver_version()[source]
Transport.on_readable(fileno)[source]

Handle AIO event for one of our file descriptors.

Transport.polling_interval = None
Transport.register_with_event_loop(connection, loop)[source]
Transport.supports_ev = True

Channel

class kombu.transport.redis.Channel(*args, **kwargs)[source]
class QoS(*args, **kwargs)
ack(delivery_tag)
append(message, delivery_tag)
pipe_or_acquire(*args, **kwds)
reject(delivery_tag, requeue=False)
restore_at_shutdown = True
restore_by_tag(tag, client=None, leftmost=False)
restore_unacked(client=None)
restore_visible(start=0, num=10, interval=10)
unacked_index_key
unacked_key
unacked_mutex_expire
unacked_mutex_key
visibility_timeout
Channel.ack_emulation = True
Channel.active_queues

Set of queues being consumed from (excluding fanout queues).

Channel.async_pool
Channel.basic_cancel(consumer_tag)[source]
Channel.basic_consume(queue, *args, **kwargs)[source]
Channel.client[source]

Client used to publish messages, BRPOP etc.

Channel.close()[source]
Channel.conn_or_acquire(*args, **kwds)[source]
Channel.fanout_patterns = False

If enabled the fanout exchange will support patterns in routing and binding keys (like a topic exchange but using PUB/SUB). This will be enabled by default in a future version.

Channel.fanout_prefix = False

Transport option to enable disable fanout keyprefix. Should be enabled by default, but that is not backwards compatible. Can also be string, in which case it changes the default prefix (‘/{db}.’) into to something else. The prefix must include a leading slash and a trailing dot.

Channel.from_transport_options = (u'body_encoding', u'deadletter_queue', 'ack_emulation', 'unacked_key', 'unacked_index_key', 'unacked_mutex_key', 'unacked_mutex_expire', 'visibility_timeout', 'unacked_restore_limit', 'fanout_prefix', 'fanout_patterns', 'socket_timeout', 'socket_connect_timeout', 'socket_keepalive', 'socket_keepalive_options', 'queue_order_strategy', 'max_connections', 'priority_steps')
Channel.get_table(exchange)[source]
Channel.keyprefix_fanout = '/{db}.'
Channel.keyprefix_queue = '_kombu.binding.%s'
Channel.max_connections = 10
Channel.pool
Channel.priority(n)[source]
Channel.priority_steps = [0, 3, 6, 9]
Channel.sep = '\x06\x16'
Channel.socket_connect_timeout = None
Channel.socket_keepalive = None
Channel.socket_keepalive_options = None
Channel.socket_timeout = None
Channel.subclient[source]

Pub/Sub connection used to consume fanout queues.

Channel.supports_fanout = True
Channel.unacked_index_key = 'unacked_index'
Channel.unacked_key = 'unacked'
Channel.unacked_mutex_expire = 300
Channel.unacked_mutex_key = 'unacked_mutex'
Channel.unacked_restore_limit = None
Channel.visibility_timeout = 3600