@classmethod
def consume_all(cls):
    """Try to consume all the message, ordered by the sequence"""
    query = cls.query().order_by(cls.sequence)
    for consumer in query.all():
        try:
            consumer.consume()
        except Exception:
            pass
