this.transportService = transportService;
this.threadPool = threadPool;
logger.info("Creating ConfigSyncService");
index = settings.get("configsync.index", ".configsync");
type = settings.get("configsync.type", "file");
<BUG>configPath = settings.get("configsync.config_path", env.configFile().getAbsolutePath());
</BUG>
scrollForUpdate = settings.get("configsync.scroll_time", "1m");
sizeForUpdate = settings.getAsInt("configsync.scroll_size", 1);
<BUG>transportService.registerHandler(ACTION_CONFIG_FLUSH, new ConfigFileFlushRequestHandler());

transportService.registerHandler(ACTION_CONFIG_RESET, new ConfigSyncResetRequestHandler());
</BUG>
}

this.transportService = transportService;
this.threadPool = threadPool;
logger.info("Creating ConfigSyncService");
index = settings.get("configsync.index", ".configsync");
type = settings.get("configsync.type", "file");
configPath = settings.get("configsync.config_path", env.configFile().toFile().getAbsolutePath());
scrollForUpdate = settings.get("configsync.scroll_time", "1m");
sizeForUpdate = settings.getAsInt("configsync.scroll_size", 1);
transportService.registerRequestHandler(ACTION_CONFIG_FLUSH,FileFlushRequest.class,ThreadPool.Names.GENERIC, new ConfigFileFlushRequestHandler());
transportService.registerRequestHandler(ACTION_CONFIG_RESET,ResetSyncRequest.class,ThreadPool.Names.GENERIC, new ConfigSyncResetRequestHandler());
}
