kombu.transport.virtual.scheduling

Consumer utilities.

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

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

close()[source]
get(**kwargs)[source]