summaryrefslogtreecommitdiffstats
path: root/catalog-be/src/main/java/org/openecomp/sdc/be/togglz/CassandraCustomStateRepository.java
diff options
context:
space:
mode:
Diffstat (limited to 'catalog-be/src/main/java/org/openecomp/sdc/be/togglz/CassandraCustomStateRepository.java')
-rw-r--r--catalog-be/src/main/java/org/openecomp/sdc/be/togglz/CassandraCustomStateRepository.java20
1 files changed, 7 insertions, 13 deletions
diff --git a/catalog-be/src/main/java/org/openecomp/sdc/be/togglz/CassandraCustomStateRepository.java b/catalog-be/src/main/java/org/openecomp/sdc/be/togglz/CassandraCustomStateRepository.java
index 5e2f416159..f8f85fdd97 100644
--- a/catalog-be/src/main/java/org/openecomp/sdc/be/togglz/CassandraCustomStateRepository.java
+++ b/catalog-be/src/main/java/org/openecomp/sdc/be/togglz/CassandraCustomStateRepository.java
@@ -17,10 +17,12 @@
* limitations under the License.
* ============LICENSE_END=========================================================
*/
-
package org.openecomp.sdc.be.togglz;
import com.google.common.annotations.VisibleForTesting;
+import java.util.List;
+import java.util.stream.Collectors;
+import javax.annotation.PostConstruct;
import org.openecomp.sdc.be.dao.cassandra.CassandraOperationStatus;
import org.openecomp.sdc.be.dao.cassandra.FeatureToggleDao;
import org.openecomp.sdc.be.resources.data.togglz.FeatureToggleEvent;
@@ -30,10 +32,6 @@ import org.togglz.core.Feature;
import org.togglz.core.repository.FeatureState;
import org.togglz.core.repository.StateRepository;
-import javax.annotation.PostConstruct;
-import java.util.List;
-import java.util.stream.Collectors;
-
@Component
public class CassandraCustomStateRepository implements StateRepository {
@@ -52,15 +50,13 @@ public class CassandraCustomStateRepository implements StateRepository {
@VisibleForTesting
void removeUnusedItems() {
List<FeatureToggleEvent> allEvents = featureToggleDao.getAllFeatures();
-
- List<FeatureToggleEvent> eventsToDelete = allEvents.stream()
- .filter(e-> ToggleableFeature.getFeatureByName(e.getFeatureName()) == null)
- .collect(Collectors.toList());
+ List<FeatureToggleEvent> eventsToDelete = allEvents.stream().filter(e -> ToggleableFeature.getFeatureByName(e.getFeatureName()) == null)
+ .collect(Collectors.toList());
if (!eventsToDelete.isEmpty()) {
logger.debug("Found Feature toggles not in use [{}], they will be deleted",
- eventsToDelete.stream().map(FeatureToggleEvent::getFeatureName).collect(Collectors.toList()));
+ eventsToDelete.stream().map(FeatureToggleEvent::getFeatureName).collect(Collectors.toList()));
}
- eventsToDelete.forEach(e->featureToggleDao.delete(e.getFeatureName()));
+ eventsToDelete.forEach(e -> featureToggleDao.delete(e.getFeatureName()));
}
@Override
@@ -71,7 +67,6 @@ public class CassandraCustomStateRepository implements StateRepository {
}
FeatureState state = null;
FeatureToggleEvent event = featureToggleDao.get(feature.name());
-
if (event != null) {
state = event.getFeatureState();
logger.debug("State of feature {} is {}", feature, state.getFeature());
@@ -87,5 +82,4 @@ public class CassandraCustomStateRepository implements StateRepository {
CassandraOperationStatus status = featureToggleDao.save(new FeatureToggleEvent(featureState));
logger.debug("setFeatureState=> FeatureState {} is set with status {}", featureState.getFeature(), status);
}
-
}