refactor(runner): add policy listener registering function and support registering McpConfigWatcher after starting

This commit is contained in:
2026-03-17 10:35:35 +08:00
parent d31cac70a6
commit 1465d7687b
2 changed files with 5 additions and 0 deletions

View File

@@ -95,6 +95,7 @@ public class LocalRunnerClient extends RunnerClient implements AutoCloseable {
executor executor
); );
configWatcher.start(); configWatcher.start();
configWatcher.registerPolicyListener();
} catch (Exception e) { } catch (Exception e) {
closeQuietly(configWatcher); closeQuietly(configWatcher);
closeQuietly(dynamicManager); closeQuietly(dynamicManager);

View File

@@ -112,4 +112,8 @@ abstract class PolicyProvider(
interface RunnerExecutionPolicyListener { interface RunnerExecutionPolicyListener {
fun onPolicyChanged(policy: ExecutionPolicy) fun onPolicyChanged(policy: ExecutionPolicy)
fun registerPolicyListener() {
ExecutionPolicyRegistry.addListener(this)
}
} }