def METHOD_NAME(self):
    repo = InMemoryMessageRepository()
    first_message = AirbyteMessage(type=Type.CONTROL, control=A_CONTROL)
    repo.emit_message(first_message)
    second_message = AirbyteMessage(type=Type.CONTROL, control=ANOTHER_CONTROL)
    repo.emit_message(second_message)
    message_generator = repo.consume_queue()
    consumed_message = next(message_generator)
    assert consumed_message == first_message
    second_message_generator = repo.consume_queue()
    assert list(second_message_generator) == [second_message]