Function dump_body

celery/worker/consumer/consumer.py:131–136

Format message body for debugging purposes.

(m, body)

def dump_body(m, body):
    """Format message body for debugging purposes."""
    # v2 protocol does not deserialize body
    body = m.body if body is None else body
    return '{} ({}b)'.format(truncate(safe_repr(body), 1024),
                             len(m.body))


class Consumer: