package org.oransc.policyagent.repository;
import com.google.common.collect.ImmutableList;
+
import java.util.Collection;
import java.util.HashMap;
import java.util.Map;
}
private Mono<RicData> startSynchronization(RicData ric) {
- RicSynchronizationTask recovery = createSynchronizationTask();
- recovery.run(ric.ric);
+ RicSynchronizationTask synchronizationTask = createSynchronizationTask();
+ synchronizationTask.run(ric.ric);
return Mono.error(new Exception("Syncronization started"));
}
@SuppressWarnings("squid:S2629")
private void onSynchronizationError(Ric ric, Throwable t) {
logger.warn("Synchronization failed for ric: {}, reason: {}", ric.name(), t.getMessage());
- // If recovery fails, try to remove all instances
+ // If synchronization fails, try to remove all instances
deleteAllPoliciesInRepository(ric);
Flux<PolicyType> recoverTypes = this.a1ClientFactory.createA1Client(ric) //
|| event.equals(ApplicationConfig.RicConfigUpdate.CHANGED)) {
Ric ric = new Ric(ricConfig);
rics.put(ric);
- RicSynchronizationTask recoveryTask =
+ RicSynchronizationTask synchronizationTask =
new RicSynchronizationTask(a1ClientFactory, policyTypes, policies, services);
- recoveryTask.run(ric);
+ synchronizationTask.run(ric);
} else if (event.equals(ApplicationConfig.RicConfigUpdate.REMOVED)) {
rics.remove(ricConfig.name());
} else {