aboutsummaryrefslogtreecommitdiffstats
path: root/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/repository/Policies.java
diff options
context:
space:
mode:
Diffstat (limited to 'a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/repository/Policies.java')
-rw-r--r--a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/repository/Policies.java38
1 files changed, 19 insertions, 19 deletions
diff --git a/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/repository/Policies.java b/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/repository/Policies.java
index 7eddeae1..ba3dd279 100644
--- a/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/repository/Policies.java
+++ b/a1-policy-management/src/main/java/org/onap/ccsdk/oran/a1policymanagementservice/repository/Policies.java
@@ -197,7 +197,7 @@ public class Policies {
byte[] bytes = gson.toJson(toStorageObject(policy)).getBytes();
this.dataStore.writeObject(this.getPath(policy), bytes) //
- .doOnError(t -> logger.error("Could not store policy in S3, reason: {}", t.getMessage())) //
+ .doOnError(t -> logger.error("Could not store policy in S3, reason: {}", t.getMessage()))
.subscribe();
}
@@ -232,29 +232,29 @@ public class Policies {
}
private PersistentPolicyInfo toStorageObject(Policy p) {
- return PersistentPolicyInfo.builder() //
- .id(p.getId()) //
- .json(p.getJson()) //
- .ownerServiceId(p.getOwnerServiceId()) //
- .ricId(p.getRic().id()) //
- .statusNotificationUri(p.getStatusNotificationUri()) //
- .typeId(p.getType().getId()) //
- .isTransient(p.isTransient()) //
- .lastModified(p.getLastModified().toString()) //
+ return PersistentPolicyInfo.builder()
+ .id(p.getId())
+ .json(p.getJson())
+ .ownerServiceId(p.getOwnerServiceId())
+ .ricId(p.getRic().id())
+ .statusNotificationUri(p.getStatusNotificationUri())
+ .typeId(p.getType().getId())
+ .isTransient(p.isTransient())
+ .lastModified(p.getLastModified().toString())
.build();
}
private Policy toPolicy(PersistentPolicyInfo p, Ric ric, PolicyTypes types) {
try {
- return Policy.builder() //
- .id(p.getId()) //
- .isTransient(p.isTransient()) //
- .json(p.getJson()) //
- .lastModified(Instant.parse(p.lastModified)) //
- .ownerServiceId(p.getOwnerServiceId()) //
- .ric(ric) //
- .statusNotificationUri(p.getStatusNotificationUri()) //
- .type(types.getType(p.getTypeId())) //
+ return Policy.builder()
+ .id(p.getId())
+ .isTransient(p.isTransient())
+ .json(p.getJson())
+ .lastModified(Instant.parse(p.lastModified))
+ .ownerServiceId(p.getOwnerServiceId())
+ .ric(ric)
+ .statusNotificationUri(p.getStatusNotificationUri())
+ .type(types.getType(p.getTypeId()))
.build();
} catch (EntityNotFoundException e) {
logger.warn("Not found: {}", e.getMessage());