kombu.transport.redis

Redis transport.

Transport

class kombu.transport.redis.Transport(*args, **kwargs)
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)
restore_unacked()
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.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.from_transport_options = ('body_encoding', 'deadletter_queue', 'ack_emulation', 'unacked_key', 'unacked_index_key', 'unacked_mutex_key', 'unacked_mutex_expire', 'visibility_timeout', 'unacked_restore_limit', 'socket_timeout', 'max_connections', 'priority_steps')
Transport.Channel.get_table(exchange)
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_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()
Transport.handle_event(fileno, event)

Handle AIO event for one of our file descriptors.

Transport.on_poll_empty()
Transport.on_poll_init(poller)

Called when hub starts.

Transport.on_poll_start()

Called by hub before each poll()

Transport.polling_interval = None
Transport.supports_ev = True

Channel

class kombu.transport.redis.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)
restore_unacked()
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.basic_cancel(consumer_tag)
Channel.basic_consume(queue, *args, **kwargs)
Channel.client

Client used to publish messages, BRPOP etc.

Channel.close()
Channel.conn_or_acquire(*args, **kwds)
Channel.from_transport_options = ('body_encoding', 'deadletter_queue', 'ack_emulation', 'unacked_key', 'unacked_index_key', 'unacked_mutex_key', 'unacked_mutex_expire', 'visibility_timeout', 'unacked_restore_limit', 'socket_timeout', 'max_connections', 'priority_steps')
Channel.get_table(exchange)
Channel.keyprefix_queue = '_kombu.binding.%s'
Channel.max_connections = 10
Channel.pool
Channel.priority(n)
Channel.priority_steps = [0, 3, 6, 9]
Channel.sep = '\x06\x16'
Channel.socket_timeout = None
Channel.subclient

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

Table Of Contents

Previous topic

kombu.transport.memory

Next topic

kombu.transport.zmq

This Page