1 files changed, 68 insertions, 0 deletions
diff --git a/openecomp-be/lib/openecomp-sdc-notification-lib/openecomp-sdc-notification-api/src/main/java/org/openecomp/sdc/notification/dao/types/SubscribersEntity.java b/openecomp-be/lib/openecomp-sdc-notification-lib/openecomp-sdc-notification-api/src/main/java/org/openecomp/sdc/notification/dao/types/SubscribersEntity.java
new file mode 100644
index 0000000000..d858cbd9eb
--- /dev/null
+++ b/openecomp-be/lib/openecomp-sdc-notification-lib/openecomp-sdc-notification-api/src/main/java/org/openecomp/sdc/notification/dao/types/SubscribersEntity.java
@@ -0,0 +1,68 @@
+package org.openecomp.sdc.notification.dao.types;
+
+import com.datastax.driver.mapping.annotations.Column;
+import com.datastax.driver.mapping.annotations.PartitionKey;
+import com.datastax.driver.mapping.annotations.Table;
+
+import java.util.Objects;
+import java.util.Set;
+
+import static java.util.Objects.hash;
+
+@Table(keyspace = "dox", name = "notification_subscribers")
+public class SubscribersEntity {
+
+    @PartitionKey
+    @Column(name = "entity_id")
+    private String entityId;
+
+    @Column(name = "subscribers")
+    private Set<String> subscribers;
+
+
+    public SubscribersEntity() {
+    }
+
+    public SubscribersEntity(String entityId, Set<String> subscribers) {
+        this.entityId = entityId;
+        this.subscribers = subscribers;
+    }
+
+    public String getEntityId() {
+        return entityId;
+    }
+
+    public void setEntityId(String entityId) {
+        this.entityId = entityId;
+    }
+
+    public Set<String> getSubscribers() {
+        return subscribers;
+    }
+
+    public void setSubscribers(Set<String> subscribers) {
+        this.subscribers = subscribers;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+        if (this == o) return true;
+        if (o == null || getClass() != o.getClass()) return false;
+        SubscribersEntity that = (SubscribersEntity) o;
+        return Objects.equals(entityId, that.entityId) &&
+                Objects.equals(subscribers, that.subscribers);
+    }
+
+    @Override
+    public int hashCode() {
+        return hash(entityId, subscribers);
+    }
+
+    @Override
+    public String toString() {
+        return "SubscribersEntity{" +
+                "entityId='" + entityId + '\'' +
+                ", subscribers=" + subscribers +
+                '}';
+    }
+}