1 2 3 4 5 6
from .simple import SimpleConsumer from .multiprocess import MultiProcessConsumer __all__ = [ 'SimpleConsumer', 'MultiProcessConsumer' ]