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)
    messages = repo.consume_queue()
    assert list(messages) == [first_message, second_message]