from .consumer import consume_messages