- private List<Module> readModules(final Config modulesConfig) {
- List<? extends ConfigObject> modulesConfigObjectList =
- modulesConfig.getObjectList("modules");
-
- final Builder<Module> b = ImmutableList.builder();
- for(ConfigObject o : modulesConfigObjectList){
- ConfigObjectWrapper w = new ConfigObjectWrapper(o);
- b.add(new Module(w.stringValue("name"), w.stringValue(
- "namespace"), w.stringValue("shard-strategy")));
- }
-
- return b.build();
- }
-
- private static List<ModuleShard> readModuleShards(final Config moduleShardsConfig) {
- List<? extends ConfigObject> moduleShardsConfigObjectList =
- moduleShardsConfig.getObjectList("module-shards");
-
- final Builder<ModuleShard> b = ImmutableList.builder();
- for(ConfigObject moduleShardConfigObject : moduleShardsConfigObjectList){
-
- String moduleName = moduleShardConfigObject.get("name").unwrapped().toString();
-
- List<? extends ConfigObject> shardsConfigObjectList =
- moduleShardConfigObject.toConfig().getObjectList("shards");
+ @Override
+ public synchronized void addModuleShardConfiguration(final ModuleShardConfiguration config) {
+ requireNonNull(config, "ModuleShardConfiguration should not be null");