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)
active_queues
basic_cancel(consumer_tag)
basic_consume(queue, *args, **kwargs)
client
close()
get_table(exchange)
keyprefix_queue = '_kombu.binding.%s'
pipeline()
sep = '\x06\x16'
subclient
supports_fanout = True
Transport.default_port = 6379
Transport.polling_interval = None

Channel

class kombu.transport.redis.Channel(*args, **kwargs)
active_queues
basic_cancel(consumer_tag)
basic_consume(queue, *args, **kwargs)
client
close()
get_table(exchange)
keyprefix_queue = '_kombu.binding.%s'
pipeline()
sep = '\x06\x16'
subclient
supports_fanout = True

Table Of Contents

Previous topic

kombu.transport.memory

Next topic

<no title>

This Page