kombu.transport.virtual.scheduling

Consumer utilities.

copyright:

3. 2009 - 2012 by Ask Solem.

license:

BSD, see LICENSE for more details.

class kombu.transport.virtual.scheduling.FairCycle(fun, resources, predicate=<type 'exceptions.Exception'>)

Consume from a set of resources, where each resource gets an equal chance to be consumed from.

close()

get(**kwargs)