kombu.transport.virtual.scheduling

Consumer utilities.

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)

Previous topic

kombu.transport.virtual.exchange

Next topic

Overview

This Page