'Create new :class:`kombu.Consumer` instance.'

def Consumer(self, queues=None, channel=None, *args, **kwargs):

    from .messaging import Consumer
    return Consumer((channel or self), queues, *args, **kwargs)
