kombu.transport.redis

Redis transport.

copyright:
  1. 2009 - 2012 by Ask Solem.
license:

BSD, see LICENSE for more details.

Transport

class kombu.transport.redis.Transport(*args, **kwargs)
class Channel(*args, **kwargs)
class QoS(*args, **kwargs)
ack(delivery_tag)
append(message, delivery_tag)
client
reject(delivery_tag, requeue=False)
restore_at_shutdown = True
restore_by_tag(tag)
restore_unacked()
restore_visible(start=0, num=10, interval=10)
unacked_index_key
unacked_key
visibility_timeout
Transport.Channel.active_queues
Transport.Channel.basic_cancel(consumer_tag)
Transport.Channel.basic_consume(queue, *args, **kwargs)
Transport.Channel.client
Transport.Channel.close()
Transport.Channel.from_transport_options = ('body_encoding', 'deadletter_queue', 'unacked_key', 'unacked_index_key', 'visibility_timeout', 'priority_steps')
Transport.Channel.get_table(exchange)
Transport.Channel.keyprefix_queue = '_kombu.binding.%s'
Transport.Channel.pipeline()
Transport.Channel.priority(n)
Transport.Channel.priority_steps = [0, 3, 6, 9]
Transport.Channel.sep = '\x06\x16'
Transport.Channel.subclient
Transport.Channel.supports_fanout = True
Transport.Channel.unacked_index_key = 'unacked_index'
Transport.Channel.unacked_key = 'unacked'
Transport.Channel.visibility_timeout = 18000
Transport.default_port = 6379
Transport.handle_event(fileno, event)
Transport.on_poll_init(poller)
Transport.on_poll_start()
Transport.polling_interval = None

Channel

class kombu.transport.redis.Channel(*args, **kwargs)
class QoS(*args, **kwargs)
ack(delivery_tag)
append(message, delivery_tag)
client
reject(delivery_tag, requeue=False)
restore_at_shutdown = True
restore_by_tag(tag)
restore_unacked()
restore_visible(start=0, num=10, interval=10)
unacked_index_key
unacked_key
visibility_timeout
Channel.active_queues
Channel.basic_cancel(consumer_tag)
Channel.basic_consume(queue, *args, **kwargs)
Channel.client
Channel.close()
Channel.from_transport_options = ('body_encoding', 'deadletter_queue', 'unacked_key', 'unacked_index_key', 'visibility_timeout', 'priority_steps')
Channel.get_table(exchange)
Channel.keyprefix_queue = '_kombu.binding.%s'
Channel.pipeline()
Channel.priority(n)
Channel.priority_steps = [0, 3, 6, 9]
Channel.sep = '\x06\x16'
Channel.subclient
Channel.supports_fanout = True
Channel.unacked_index_key = 'unacked_index'
Channel.unacked_key = 'unacked'
Channel.visibility_timeout = 18000

Table Of Contents

Previous topic

kombu.transport.memory

Next topic

<no title>

This Page