'Callback called if an error occurs while decoding a message.
Simply logs the error and acknowledges the message so it
doesn\'t enter a loop.
Arguments:
message (kombu.Message): The message received.
exc (Exception): The exception being handled.'

def on_decode_error(self, message, exc):

    crit(MESSAGE_DECODE_ERROR, exc, message.content_type, message.content_encoding, safe_repr(message.headers), dump_body(message, message.body), exc_info=1)
    message.ack()
