def METHOD_NAME(self):
    repo = NoopMessageRepository()
    repo.emit_message(AirbyteMessage(type=Type.CONTROL, control=A_CONTROL))
    repo.log_message(Level.INFO, lambda: "this is a log message")
    assert not list(repo.consume_queue())