Merge "Code review cleanup for: Add kafka messaging support to integration test module"

[cps.git] / cps-ncmp-service / src / main / java / org / onap / cps / ncmp / api / impl / events / cmsubscription / service / CmNotificationSubscriptionPersistenceService.java

diff --git a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/events/cmsubscription/service/CmNotificationSubscriptionPersistenceService.java b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/events/cmsubscription/service/CmNotificationSubscriptionPersistenceService.java
index 189fbb5..6b02adb 100644 (file)
--- a/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/events/cmsubscription/service/CmNotificationSubscriptionPersistenceService.java
+++ b/cps-ncmp-service/src/main/java/org/onap/cps/ncmp/api/impl/events/cmsubscription/service/CmNotificationSubscriptionPersistenceService.java
@@ -39,6 +39,14 @@ public interface CmNotificationSubscriptionPersistenceService {
     boolean isOngoingCmNotificationSubscription(final DatastoreType datastoreType, final String cmHandleId,
             final String xpath);
 
+    /**
+     * Check if the subscription ID is unique against ongoing subscriptions.
+     *
+     * @param subscriptionId subscription ID
+     * @return true if subscriptionId is not used in active subscriptions, otherwise false
+     */
+    boolean isUniqueSubscriptionId(final String subscriptionId);
+
     /**
      * Get all ongoing cm notification subscription based on the parameters.
      *
@@ -49,4 +57,15 @@ public interface CmNotificationSubscriptionPersistenceService {
      */
     Collection<String> getOngoingCmNotificationSubscriptionIds(final DatastoreType datastoreType,
             final String cmHandleId, final String xpath);
+
+    /**
+     * Add or update cm notification subscription.
+     *
+     * @param datastoreType valid datastore type
+     * @param cmHandle cmhandle id
+     * @param xpath valid xpath
+     * @param newSubscriptionId subscription Id to be added
+     */
+    void addOrUpdateCmNotificationSubscription(final DatastoreType datastoreType, final String cmHandle,
+                                               final String xpath, final String newSubscriptionId);
 }