summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java')
-rw-r--r--src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java b/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java
index 550c185..3507d63 100644
--- a/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java
+++ b/src/main/java/org/onap/nbi/apis/hub/service/SubscriptionService.java
@@ -15,6 +15,7 @@ package org.onap.nbi.apis.hub.service;
import com.google.common.collect.Lists;
import java.text.MessageFormat;
import java.util.List;
+import java.util.Optional;
import org.onap.nbi.apis.hub.model.Subscriber;
import org.onap.nbi.apis.hub.model.Subscription;
import org.onap.nbi.apis.hub.repository.SubscriberRepository;
@@ -30,8 +31,8 @@ public class SubscriptionService {
@Autowired
SubscriberRepository subscriberRepository;
- public Subscriber findSubscriptionById(String subscriptionId) {
- return subscriberRepository.findOne(subscriptionId);
+ public Optional<Subscriber> findSubscriptionById(String subscriptionId) {
+ return subscriberRepository.findById(subscriptionId);
}
public Subscriber createSubscription(Subscription subscription) {
@@ -51,12 +52,12 @@ public class SubscriptionService {
private boolean isSubscriberAlreadyExisting(Subscriber subscriber) {
Example<Subscriber> subscriberExample = Example.of(subscriber);
- Subscriber subscriberAlreadyExisting = subscriberRepository.findOne(subscriberExample);
- return subscriberAlreadyExisting != null;
+ Optional<Subscriber> subscriberAlreadyExisting = subscriberRepository.findOne(subscriberExample);
+ return subscriberAlreadyExisting.isPresent();
}
public void deleteSubscription(String subscriptionId) {
- subscriberRepository.delete(subscriptionId);
+ subscriberRepository.deleteById(subscriptionId);
}
public void deleteAll() {