'Method called when a message is received.
This dispatches to the registered :attr:`callbacks`.
Arguments:
body (Any): The decoded message body.
message (~kombu.Message): The message instance.
Raises:
NotImplementedError: If no consumer callbacks have been
registered.'

def receive(self, body, message):

    callbacks = self.callbacks
    if (not callbacks):
        raise NotImplementedError(u'Consumer    does    not    have    any    callbacks')
    [callback(body, message) for callback in callbacks]
