aboutsummaryrefslogtreecommitdiffstats
path: root/dcae_dmaapbc_model/src
diff options
context:
space:
mode:
authorChristopher Lott (cl778h) <clott@research.att.com>2017-05-09 14:24:20 -0400
committerChristopher Lott (cl778h) <clott@research.att.com>2017-05-09 14:44:09 -0400
commite2aefda183de4f1c1256d97f7ce09f8bee5477db (patch)
tree4b0eaf3f153df90591711daf081e63a8b20ace74 /dcae_dmaapbc_model/src
parent472635713b7471b300a988db7e907bab0119eaee (diff)
[ONAP-rebase] Rebase as 1.1.0-SNAPSHOT
Consolidate into a single maven project; no more separate model and client jars. Change-Id: Ibbba982250b74c0dfd09ee1c65c0fb6c158dd632 Signed-off-by: Christopher Lott <cl778h@att.com> Signed-off-by: Christopher Lott (cl778h) <clott@research.att.com>
Diffstat (limited to 'dcae_dmaapbc_model/src')
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Node.java87
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Pub.java96
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Sub.java152
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DcaeLocation.java97
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Dmaap.java141
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DmaapObject.java70
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/ErrorResponse.java65
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Feed.java193
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/MR_Client.java110
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/MR_Cluster.java102
-rw-r--r--dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Topic.java122
11 files changed, 0 insertions, 1235 deletions
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Node.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Node.java
deleted file mode 100644
index 87ad86e..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Node.java
+++ /dev/null
@@ -1,87 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-/**
- * Bean that models a DMaaP Data Router node.
- */
-public class DR_Node extends DmaapObject {
-
- private String fqdn;
- /** dcaeLocation where node VM is deployed */
- private String dcaeLocationName;
- /**
- * name for this VM (sometimes this is a local VM name and may be different
- * than FQDN)
- */
- private String hostName;
- /** version of Node software package */
- private String version;
-
- public DR_Node() {
- }
-
- public DR_Node(String lastMod, Dmaap_Status status, String fqdn, String dcaeLocationName, String hostName,
- String version) {
- super(lastMod, status);
- this.fqdn = fqdn;
- this.dcaeLocationName = dcaeLocationName;
- this.hostName = hostName;
- this.version = version;
- }
-
- public String getFqdn() {
- return fqdn;
- }
-
- public void setFqdn(String fqdn) {
- this.fqdn = fqdn;
- }
-
- public String getDcaeLocationName() {
- return dcaeLocationName;
- }
-
- public void setDcaeLocationName(String dcaeLocationName) {
- this.dcaeLocationName = dcaeLocationName;
- }
-
- public String getHostName() {
- return hostName;
- }
-
- public void setHostName(String hostName) {
- this.hostName = hostName;
- }
-
- public String getVersion() {
- return version;
- }
-
- public void setVersion(String version) {
- this.version = version;
- }
-
- @Override
- public String toString() {
- return "DR_Node[fqdn=" + fqdn + ", dcaeLocationName=" + dcaeLocationName + ", ...]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Pub.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Pub.java
deleted file mode 100644
index fe0aeca..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Pub.java
+++ /dev/null
@@ -1,96 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-/**
- * Bean that models a DMaaP Data Router publisher.
- */
-public class DR_Pub extends DmaapObject {
-
- /** dcaeLocation tag where this publisher is deployed */
- private String dcaeLocationName;
- /** name used for basic authentication to DR */
- private String username;
- /** password used for basic authentication to DR */
- private String userpwd;
- /** tag of feed for which this publisher is a source */
- private String feedId;
- /** unique id of a DCAE publisher (generated by Data Router PROV) */
- private String pubId;
-
- public DR_Pub() {
- }
-
- public DR_Pub(Dmaap_Status status, String lastMod, String dcaeLocationName, String username, String userpwd,
- String feedId, String pubId) {
- super(lastMod, status);
- this.dcaeLocationName = dcaeLocationName;
- this.username = username;
- this.userpwd = userpwd;
- this.feedId = feedId;
- this.pubId = pubId;
- }
-
- public String getDcaeLocationName() {
- return dcaeLocationName;
- }
-
- public void setDcaeLocationName(String dcaeLocationName) {
- this.dcaeLocationName = dcaeLocationName;
- }
-
- public String getUsername() {
- return username;
- }
-
- public void setUsername(String username) {
- this.username = username;
- }
-
- public String getUserpwd() {
- return userpwd;
- }
-
- public void setUserpwd(String userpwd) {
- this.userpwd = userpwd;
- }
-
- public String getFeedId() {
- return feedId;
- }
-
- public void setFeedId(String feedId) {
- this.feedId = feedId;
- }
-
- public String getPubId() {
- return pubId;
- }
-
- public void setPubId(String pubId) {
- this.pubId = pubId;
- }
-
- @Override
- public String toString() {
- return "DR_Pub[dcaeLocationName=" + dcaeLocationName + ", feedId=" + feedId + ", ...]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Sub.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Sub.java
deleted file mode 100644
index 45adf9c..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DR_Sub.java
+++ /dev/null
@@ -1,152 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-/**
- * Bean that models a DMaaP Data Router subscriber.
- */
-public class DR_Sub extends DmaapObject {
-
- /** Tag where this publisher is deployed */
- private String dcaeLocationName;
- /** name used for basic authentication from DR */
- private String username;
- /** password used for basic authentication from DR */
- private String userpwd;
- /** tag of feed for which this publisher is a source */
- private String feedId;
- /** URL used by DR to deliver files to this subscriber */
- private String deliveryURL;
- /** URL for accessing the transaction log for this susbcriber */
- private String logURL;
- /** unique ID for a subscriber in this DR environment */
- private String subId;
- /** TODO */
- private boolean suspended;
- /** TODO */
- private boolean use100;
- /** TODO */
- private String owner;
-
- public DR_Sub() {
- }
-
- public DR_Sub(String lastMod, Dmaap_Status status, String dcaeLocationName, String username, String userpwd,
- String feedId, String deliveryURL, String logURL, String subId, boolean suspended, boolean use100,
- String owner) {
- super(lastMod, status);
- this.dcaeLocationName = dcaeLocationName;
- this.username = username;
- this.userpwd = userpwd;
- this.feedId = feedId;
- this.deliveryURL = deliveryURL;
- this.logURL = logURL;
- this.subId = subId;
- this.suspended = suspended;
- this.use100 = use100;
- this.owner = owner;
- }
-
- public String getDcaeLocationName() {
- return dcaeLocationName;
- }
-
- public void setDcaeLocationName(String dcaeLocationName) {
- this.dcaeLocationName = dcaeLocationName;
- }
-
- public String getUsername() {
- return username;
- }
-
- public void setUsername(String username) {
- this.username = username;
- }
-
- public String getUserpwd() {
- return userpwd;
- }
-
- public void setUserpwd(String userpwd) {
- this.userpwd = userpwd;
- }
-
- public String getFeedId() {
- return feedId;
- }
-
- public void setFeedId(String feedId) {
- this.feedId = feedId;
- }
-
- public String getDeliveryURL() {
- return deliveryURL;
- }
-
- public void setDeliveryURL(String deliveryURL) {
- this.deliveryURL = deliveryURL;
- }
-
- public String getLogURL() {
- return logURL;
- }
-
- public void setLogURL(String logURL) {
- this.logURL = logURL;
- }
-
- public String getSubId() {
- return subId;
- }
-
- public void setSubId(String subId) {
- this.subId = subId;
- }
-
- public String getOwner() {
- return owner;
- }
-
- public void setOwner(String owner) {
- this.owner = owner;
- }
-
- public boolean isSuspended() {
- return suspended;
- }
-
- public void setSuspended(boolean suspended) {
- this.suspended = suspended;
- }
-
- public boolean isUse100() {
- return use100;
- }
-
- public void setUse100(boolean use100) {
- this.use100 = use100;
- }
-
- @Override
- public String toString() {
- return "DR_Sub[dcaeLocationName=" + dcaeLocationName + ", feedId=" + feedId + ", ...]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DcaeLocation.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DcaeLocation.java
deleted file mode 100644
index 3e072e9..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DcaeLocation.java
+++ /dev/null
@@ -1,97 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-/**
- * Bean that models a DMaaP DCAE location.
- */
-public class DcaeLocation extends DmaapObject {
-
- public enum Dcae_Status {
- EMPTY, NEW, STAGED, VALID, INVALID
- }
-
- /**
- * AT&T network location code used to identify the location. (might there be more
- * than one location per clli?)
- */
- private String clli;
- /**
- * indicator of DCAE layer. Either opendcae-central or opendcae-local-ntc
- */
- private String dcaeLayer;
- /**
- * unique name of this dcaeLocation. Value should match what DCAE Controller
- * uses.
- */
- private String dcaeLocationName;
- /** determines “where,� within the OpenStack deployment, the edge exists */
- private String openStackAvailabilityZone;
-
- public DcaeLocation() {
- }
-
- public DcaeLocation(String lastMod, Dmaap_Status status, String clli, String dcaeLayer, String dcaeLocationName,
- String openStackAvailabilityZone) {
- super(lastMod, status);
- this.clli = clli;
- this.dcaeLayer = dcaeLayer;
- this.dcaeLocationName = dcaeLocationName;
- this.openStackAvailabilityZone = openStackAvailabilityZone;
- }
-
- public String getClli() {
- return clli;
- }
-
- public void setClli(String clli) {
- this.clli = clli;
- }
-
- public String getDcaeLayer() {
- return dcaeLayer;
- }
-
- public void setDcaeLayer(String dcaeLayer) {
- this.dcaeLayer = dcaeLayer;
- }
-
- public String getDcaeLocationName() {
- return dcaeLocationName;
- }
-
- public void setDcaeLocationName(String dcaeLocationName) {
- this.dcaeLocationName = dcaeLocationName;
- }
-
- public String getOpenStackAvailabilityZone() {
- return openStackAvailabilityZone;
- }
-
- public void setOpenStackAvailabilityZone(String openStackAvailabilityZone) {
- this.openStackAvailabilityZone = openStackAvailabilityZone;
- }
-
- @Override
- public String toString() {
- return "DcaeLocation[dcaeLocationName=" + dcaeLocationName + ", dcaeLayer=" + dcaeLayer + ", ...]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Dmaap.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Dmaap.java
deleted file mode 100644
index a644e2f..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Dmaap.java
+++ /dev/null
@@ -1,141 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-/**
- * Bean that models a DMaaP instance.
- */
-public class Dmaap extends DmaapObject {
-
- /** the version of DMaaP BC software */
- private String version;
- /** the root portion of the topic namespace */
- private String topicNsRoot;
- /**
- * a unique identifier for this instance. e.g. 1607.somersetLab or 1607.FTL
- */
- private String dmaapName;
- /** URL for DR Provisioning Server */
- private String drProvUrl;
- /**
- * topic name used by MR Bridge Admin to communicate which topics to
- * replicate
- */
- private String bridgeAdminTopic;
- /** used by DCAE Controller to upload event logs */
- private String loggingUrl;
- /** used by DCAE Controller to authenticate inter-node messages */
- private String nodeKey;
- /** used by DCAE Controller to set up ssh access to VMs */
- private String accessKeyOwner;
-
- public Dmaap() {
- }
-
- public Dmaap(String lastMod, Dmaap_Status status, String version, String topicNsRoot, String dmaapName,
- String drProvUrl, String loggingUrl, String nodeKey, String accessKeyOwner) {
- super(lastMod, status);
- this.version = version;
- this.topicNsRoot = topicNsRoot;
- this.dmaapName = dmaapName;
- this.drProvUrl = drProvUrl;
- this.loggingUrl = loggingUrl;
- this.nodeKey = nodeKey;
- this.accessKeyOwner = accessKeyOwner;
- }
-
- public String getVersion() {
- return version;
- }
-
- public void setVersion(String version) {
- this.version = version;
- }
-
- public String getTopicNsRoot() {
- return topicNsRoot;
- }
-
- public void setTopicNsRoot(String topicNsRoot) {
- this.topicNsRoot = topicNsRoot;
- }
-
- public String getDmaapName() {
- return dmaapName;
- }
-
- public void setDmaapName(String dmaapName) {
- this.dmaapName = dmaapName;
- }
-
- public String getDrProvUrl() {
- return drProvUrl;
- }
-
- public void setDrProvUrl(String drProvUrl) {
- this.drProvUrl = drProvUrl;
- }
-
- public String getLogginUrl() {
- return loggingUrl;
- }
-
- public void setLogginUrl(String logginUrl) {
- this.loggingUrl = logginUrl;
- }
-
- public String getNodeKey() {
- return nodeKey;
- }
-
- public void setNodeKey(String nodeKey) {
- this.nodeKey = nodeKey;
- }
-
- public String getAccessKeyOwner() {
- return accessKeyOwner;
- }
-
- public void setAccessKeyOwner(String accessKeyOwner) {
- this.accessKeyOwner = accessKeyOwner;
- }
-
- public String getLoggingUrl() {
- return loggingUrl;
- }
-
- public void setLoggingUrl(String loggingUrl) {
- this.loggingUrl = loggingUrl;
- }
-
- public String getBridgeAdminTopic() {
- return bridgeAdminTopic;
- }
-
- public void setBridgeAdminTopic(String bridgeAdminTopic) {
- this.bridgeAdminTopic = bridgeAdminTopic;
- }
-
- @Override
- public String toString() {
- return "Dmaap[dmaapName=" + dmaapName + ", version=" + version + ", ...]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DmaapObject.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DmaapObject.java
deleted file mode 100644
index fc66281..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/DmaapObject.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-/**
- * Parent class for all DMaaP BC models.
- */
-public abstract class DmaapObject {
-
- public enum Dmaap_Status {
- EMPTY, NEW, STAGED, VALID, INVALID //, DELETED
- }
-
- /** time stamp when object was last modified */
- private String lastMod;
- /** indicator of health of this object using values common in this API */
- private Dmaap_Status status;
- /** TODO */
- private String type;
-
- public DmaapObject() {
- }
-
- public DmaapObject(String lastMod, Dmaap_Status status) {
- this.lastMod = lastMod;
- this.status = status;
- }
-
- public String getLastMod() {
- return lastMod;
- }
-
- public void setLastMod(String lastMod) {
- this.lastMod = lastMod;
- }
-
- public Dmaap_Status getStatus() {
- return status;
- }
-
- public void setStatus(Dmaap_Status status) {
- this.status = status;
- }
-
- public String getType() {
- return type;
- }
-
- public void setType(String type) {
- this.type = type;
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/ErrorResponse.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/ErrorResponse.java
deleted file mode 100644
index 2cdb182..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/ErrorResponse.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-/**
- * Bean that models a DMaaP Bus Controller error response.
- *
- * This inherits some fields (e.g., lastMod and status) that are not used.
- */
-public class ErrorResponse extends DmaapObject {
-
- private Integer code;
- private String message;
- private String fields;
-
- public ErrorResponse() {
- }
-
- public Integer getCode() {
- return code;
- }
-
- public void setCode(Integer code) {
- this.code = code;
- }
-
- public String getMessage() {
- return message;
- }
-
- public void setMessage(String message) {
- this.message = message;
- }
-
- public String getFields() {
- return fields;
- }
-
- public void setFields(String fields) {
- this.fields = fields;
- }
-
- @Override
- public String toString() {
- return "ErrorResponse[code=" + code + ", message=" + message + ", fields=" + fields + "]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Feed.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Feed.java
deleted file mode 100644
index f56aa54..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Feed.java
+++ /dev/null
@@ -1,193 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * Bean that models a DMaaP Data Router feed.
- */
-public class Feed extends DmaapObject {
-
- public enum Feed_Status {
- EMPTY, NEW, STAGED, VALID, INVALID, DELETED
- }
-
- /** unique id assigned by the DR PROV server for this feed */
- private String feedId;
- /** name of feed. Combined with feedVersion must be unique */
- private String feedName;
- /** version of feed. Combined with feedName must be unique */
- private String feedVersion;
- /** description */
- private String feedDescription;
- /** ASPR classification */
- private String asprClassification;
- /** provisioning URL for adding subscribers to this feed */
- private String subscribeURL;
- /** URL publisher use to connect to DR */
- private String publishURL;
- /** URL for transaction log for this feed */
- private String logURL;
- /** indicator of whether the feed is suspended */
- private boolean suspended;
- /** what identity owns this feed */
- private String owner;
- /** id of format description of feed content */
- private String formatUuid;
- /** a set of publishers for this feed */
- private List<DR_Pub> pubs;
- /** a set of subscribers for this feed */
- private List<DR_Sub> subs;
-
- public Feed() {
- this.pubs = new ArrayList<DR_Pub>();
- this.subs = new ArrayList<DR_Sub>();
- }
-
- public Feed(Dmaap_Status status, String lastMod, String feedName, String feedVersion, String feedDescription,
- String asprClassification, String subscribeURL, String publishURL, String logURL, boolean suspended,
- String owner, String formatUuid) {
- super(lastMod, status);
- this.feedName = feedName;
- this.feedVersion = feedVersion;
- this.feedDescription = feedDescription;
- this.asprClassification = asprClassification;
- this.subscribeURL = subscribeURL;
- this.publishURL = publishURL;
- this.logURL = logURL;
- this.suspended = suspended;
- this.owner = owner;
- this.formatUuid = formatUuid;
- this.pubs = new ArrayList<DR_Pub>();
- this.subs = new ArrayList<DR_Sub>();
- }
-
- public String getFeedId() {
- return feedId;
- }
-
- public void setFeedId(String feedId) {
- this.feedId = feedId;
- }
-
- public String getFeedName() {
- return feedName;
- }
-
- public void setFeedName(String feedName) {
- this.feedName = feedName;
- }
-
- public String getFeedVersion() {
- return feedVersion;
- }
-
- public void setFeedVersion(String feedVersion) {
- this.feedVersion = feedVersion;
- }
-
- public String getFeedDescription() {
- return feedDescription;
- }
-
- public void setFeedDescription(String feedDescription) {
- this.feedDescription = feedDescription;
- }
-
- public String getOwner() {
- return owner;
- }
-
- public void setOwner(String owner) {
- this.owner = owner;
- }
-
- public String getAsprClassification() {
- return asprClassification;
- }
-
- public void setAsprClassification(String asprClassification) {
- this.asprClassification = asprClassification;
- }
-
- public String getSubscribeURL() {
- return subscribeURL;
- }
-
- public void setSubscribeURL(String subscribeURL) {
- this.subscribeURL = subscribeURL;
- }
-
- public String getPublishURL() {
- return publishURL;
- }
-
- public void setPublishURL(String publishURL) {
- this.publishURL = publishURL;
- }
-
- public String getLogURL() {
- return logURL;
- }
-
- public void setLogURL(String logURL) {
- this.logURL = logURL;
- }
-
- public boolean isSuspended() {
- return suspended;
- }
-
- public void setSuspended(boolean suspended) {
- this.suspended = suspended;
- }
-
- public String getFormatUuid() {
- return formatUuid;
- }
-
- public void setFormatUuid(String formatUuid) {
- this.formatUuid = formatUuid;
- }
-
- public List<DR_Pub> getPubs() {
- return pubs;
- }
-
- public void setPubs(List<DR_Pub> pubs) {
- this.pubs = pubs;
- }
-
- public List<DR_Sub> getSubs() {
- return subs;
- }
-
- public void setSubs(List<DR_Sub> subs) {
- this.subs = subs;
- }
-
- @Override
- public String toString() {
- return "Feed[feedId=" + feedId + ", feedName=" + feedName + ", feedVersion=" + feedVersion + ", ...]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/MR_Client.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/MR_Client.java
deleted file mode 100644
index a1abc70..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/MR_Client.java
+++ /dev/null
@@ -1,110 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-/**
- * Bean that models a DMaaP Message Router client.
- */
-public class MR_Client extends DmaapObject {
-
- /** dcaeLocation tag where this client is deployed */
- private String dcaeLocationName;
- /** fully qualified topic name */
- private String fqtn;
- /**
- * name of role of client which will be
- * granted the AAF permission associated with any action
- */
- private String clientRole;
- /** an array of actions. Current possibilities are view, pub, sub */
- private String[] action;
- /** unique handle for this client, generated by DMaaP Bus Controller */
- private String mrClientId;
- /** TODO */
- private String topicURL;
-
- public MR_Client() {
- }
-
- public MR_Client(String lastMod, Dmaap_Status status, String dcaeLocationName, String fqtn, String clientRole,
- String[] action, String mrClientId, String topicURL) {
- super(lastMod, status);
- this.dcaeLocationName = dcaeLocationName;
- this.fqtn = fqtn;
- this.clientRole = clientRole;
- this.action = action;
- this.mrClientId = mrClientId;
- this.topicURL = topicURL;
- }
-
- public String getDcaeLocationName() {
- return dcaeLocationName;
- }
-
- public void setDcaeLocationName(String dcaeLocationName) {
- this.dcaeLocationName = dcaeLocationName;
- }
-
- public String getFqtn() {
- return fqtn;
- }
-
- public void setFqtn(String fqtn) {
- this.fqtn = fqtn;
- }
-
- public String getClientRole() {
- return clientRole;
- }
-
- public void setClientRole(String clientRole) {
- this.clientRole = clientRole;
- }
-
- public String[] getAction() {
- return action;
- }
-
- public void setAction(String[] action) {
- this.action = action;
- }
-
- public String getMrClientId() {
- return mrClientId;
- }
-
- public void setMrClientId(String mrClientId) {
- this.mrClientId = mrClientId;
- }
-
- public String getTopicURL() {
- return topicURL;
- }
-
- public void setTopicURL(String topicURL) {
- this.topicURL = topicURL;
- }
-
- @Override
- public String toString() {
- return "MR_Client[dcaeLocationName=" + dcaeLocationName + ", fqtn=" + fqtn + ", ...]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/MR_Cluster.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/MR_Cluster.java
deleted file mode 100644
index 21d87cf..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/MR_Cluster.java
+++ /dev/null
@@ -1,102 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-import java.util.List;
-
-/**
- * Bean that models a DMaaP Message Router cluster.
- */
-public class MR_Cluster extends DmaapObject {
-
- /** dcaeLocation where cluster VMs are deployed */
- private String dcaeLocationName;
- /** DNS name used by MR clients for this cluster */
- private String fqdn;
- /** an array of hosts that are part of the MR Cluster. */
- private List<String> hosts;
- /** TODO */
- private String topicPort;
- /** TODO */
- private String topicProtocol;
-
- public MR_Cluster() {
- }
-
- /**
- * @param dcaeLocationName
- * @param fqdn
- * @param hosts
- */
- public MR_Cluster(Dmaap_Status status, String lastMod, String dcaeLocationName, String fqdn,
- final String[] hosts) {
- super(lastMod, status);
- this.dcaeLocationName = dcaeLocationName;
- this.fqdn = fqdn;
- for (String h : hosts)
- this.hosts.add(h);
- }
-
- public String getDcaeLocationName() {
- return dcaeLocationName;
- }
-
- public void setDcaeLocationName(String dcaeLocationName) {
- this.dcaeLocationName = dcaeLocationName;
- }
-
- public String getFqdn() {
- return fqdn;
- }
-
- public void setFqdn(String fqdn) {
- this.fqdn = fqdn;
- }
-
- public List<String> getHosts() {
- return hosts;
- }
-
- public void setHosts(List<String> hosts) {
- this.hosts = hosts;
- }
-
- public String getTopicPort() {
- return topicPort;
- }
-
- public void setTopicPort(String topicPort) {
- this.topicPort = topicPort;
- }
-
- public String getTopicProtocol() {
- return topicProtocol;
- }
-
- public void setTopicProtocol(String topicProtocol) {
- this.topicProtocol = topicProtocol;
- }
-
- @Override
- public String toString() {
- return "MR_Cluster[dcaeLocationName=" + dcaeLocationName + ", fqdn=" + fqdn + ", ...]";
- }
-
-}
diff --git a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Topic.java b/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Topic.java
deleted file mode 100644
index b76a34b..0000000
--- a/dcae_dmaapbc_model/src/main/java/org/openecomp/dcae/dmaapbc/model/Topic.java
+++ /dev/null
@@ -1,122 +0,0 @@
-/*-
- * ================================================================================
- * DCAE DMaaP Bus Controller Models
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ================================================================================
- */
-package org.openecomp.dcae.dmaapbc.model;
-
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * Bean that models a DMaaP Message Router topic.
- */
-public class Topic extends DmaapObject {
-
- /** fully qualified topic name (topic_ns_root.environment.topic_name) */
- private String fqtn;
- /** application supplied value for topicName */
- private String topicName;
- /** description of topic */
- private String topicDescription;
- /** what identity owns this topic */
- private String owner;
- /** flag to MR indicating whether transactions are enabled for this topic */
- private String tnxEnabled;
- /** id of format description of feed content */
- private String formatUuid;
- /** a set of publishers and subscribers for this topic */
- private List<MR_Client> clients;
-
- public Topic() {
- this.clients = new ArrayList<MR_Client>();
- }
-
- public Topic(String lastMod, Dmaap_Status status, String fqtn, String topicName, String topicDescription,
- String owner, String tnxEnabled, String formatUuid) {
- super(lastMod, status);
- this.fqtn = fqtn;
- this.topicName = topicName;
- this.topicDescription = topicDescription;
- this.owner = owner;
- this.tnxEnabled = tnxEnabled;
- this.formatUuid = formatUuid;
- this.clients = new ArrayList<MR_Client>();
- }
-
- public String getFqtn() {
- return fqtn;
- }
-
- public void setFqtn(String fqtn) {
- this.fqtn = fqtn;
- }
-
- public String getTopicName() {
- return topicName;
- }
-
- public void setTopicName(String topicName) {
- this.topicName = topicName;
- }
-
- public String getTopicDescription() {
- return topicDescription;
- }
-
- public void setTopicDescription(String topicDescription) {
- this.topicDescription = topicDescription;
- }
-
- public String getTnxEnabled() {
- return tnxEnabled;
- }
-
- public void setTnxEnabled(String tnxEnabled) {
- this.tnxEnabled = tnxEnabled;
- }
-
- public String getOwner() {
- return owner;
- }
-
- public void setOwner(String owner) {
- this.owner = owner;
- }
-
- public String getFormatUuid() {
- return formatUuid;
- }
-
- public void setFormatUuid(String formatUuid) {
- this.formatUuid = formatUuid;
- }
-
- public List<MR_Client> getClients() {
- return clients;
- }
-
- public void setClients(List<MR_Client> clients) {
- this.clients = clients;
- }
-
- @Override
- public String toString() {
- return "Topic[fqtn=" + fqtn + ", topicName=" + topicName + ", ...]";
- }
-
-}