aboutsummaryrefslogtreecommitdiffstats
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/main/java/org/onap/dmaap/dbcapi/model/Feed.java98
1 files changed, 47 insertions, 51 deletions
diff --git a/src/main/java/org/onap/dmaap/dbcapi/model/Feed.java b/src/main/java/org/onap/dmaap/dbcapi/model/Feed.java
index b78377b..b3c7332 100644
--- a/src/main/java/org/onap/dmaap/dbcapi/model/Feed.java
+++ b/src/main/java/org/onap/dmaap/dbcapi/model/Feed.java
@@ -48,52 +48,32 @@ public class Feed extends DmaapObject {
private String formatUuid;
private ArrayList<DR_Pub> pubs;
- private ArrayList<DR_Sub> subs;
+ private ArrayList<DR_Sub> subs;
-
-
- public boolean isSuspended() {
- return suspended;
- }
-
- public void setSuspended(boolean suspended) {
- this.suspended = suspended;
- }
-
- public String getSubscribeURL() {
- return subscribeURL;
- }
- public void setSubscribeURL(String subscribeURL) {
- this.subscribeURL = subscribeURL;
- }
-
-
-
public Feed() {
- this.pubs = new ArrayList<DR_Pub>();
- this.subs = new ArrayList<DR_Sub>();
+ this.pubs = new ArrayList<>();
+ this.subs = new ArrayList<>();
this.setStatus( DmaapObject_Status.EMPTY );
-
+
}
-
+
public Feed( String name,
- String version,
- String description,
- String owner,
- String aspr
- ) {
+ String version,
+ String description,
+ String owner,
+ String aspr) {
this.feedName = name;
this.feedVersion = version;
this.feedDescription = description;
this.owner = owner;
this.asprClassification = aspr;
- this.pubs = new ArrayList<DR_Pub>();
- this.subs = new ArrayList<DR_Sub>();
+ this.pubs = new ArrayList<>();
+ this.subs = new ArrayList<>();
this.setStatus( DmaapObject_Status.NEW );
-
+
}
-
+
// expects a String in JSON format, with known fields to populate Feed object
public Feed ( String json ) {
JSONParser parser = new JSONParser();
@@ -101,10 +81,10 @@ public class Feed extends DmaapObject {
try {
jsonObj = (JSONObject) parser.parse( json );
} catch ( ParseException pe ) {
- logger.error( "Error parsing provisioning data: " + json );
- this.setStatus( DmaapObject_Status.INVALID );
- return;
- }
+ logger.error( "Error parsing provisioning data: " + json );
+ this.setStatus( DmaapObject_Status.INVALID );
+ return;
+ }
this.setFeedName( (String) jsonObj.get("name"));
this.setFeedVersion( (String) jsonObj.get("version"));
@@ -117,30 +97,48 @@ public class Feed extends DmaapObject {
this.setPublishURL( url );
this.setFeedId( url.substring( url.lastIndexOf('/')+1, url.length() ));
logger.info( "feedid="+ this.getFeedId() );
- this.setSubscribeURL( (String) links.get("subscribe") );
+ this.setSubscribeURL( (String) links.get("subscribe") );
this.setLogURL( (String) links.get("log") );
JSONObject auth = (JSONObject) jsonObj.get("authorization");
this.setAsprClassification( (String) auth.get("classification"));
JSONArray pubs = (JSONArray) auth.get( "endpoint_ids");
int i;
- ArrayList<DR_Pub> dr_pub = new ArrayList<DR_Pub>();
- this.subs = new ArrayList<DR_Sub>();
+ ArrayList<DR_Pub> dr_pub = new ArrayList<>();
+ this.subs = new ArrayList<>();
for( i = 0; i < pubs.size(); i++ ) {
JSONObject entry = (JSONObject) pubs.get(i);
- dr_pub.add( new DR_Pub( "someLocation",
- (String) entry.get("id"),
- (String) entry.get("password"),
- this.getFeedId(),
- this.getFeedId() + "." + DR_Pub.nextKey() ));
-
+ dr_pub.add( new DR_Pub( "someLocation",
+ (String) entry.get("id"),
+ (String) entry.get("password"),
+ this.getFeedId(),
+ this.getFeedId() + "." + DR_Pub.nextKey() ));
+
}
this.setPubs( dr_pub );
-
+
this.setStatus( DmaapObject_Status.VALID );
}
+
+
+ public boolean isSuspended() {
+ return suspended;
+ }
+
+ public void setSuspended(boolean suspended) {
+ this.suspended = suspended;
+ }
+
+ public String getSubscribeURL() {
+ return subscribeURL;
+ }
+
+ public void setSubscribeURL(String subscribeURL) {
+ this.subscribeURL = subscribeURL;
+ }
+
public String getFeedId() {
return feedId;
}
@@ -218,8 +216,7 @@ public class Feed extends DmaapObject {
// returns the Feed object in JSON that conforms to DR Prov Server expectations
public String toProvJSON() {
- ArrayList<DR_Pub> pubs = this.getPubs();
- String postJSON = String.format("{\"name\": \"%s\", \"version\": \"%s\", \"description\": \"%s\", \"suspend\": %s, \"authorization\": { \"classification\": \"%s\", ",
+ String postJSON = String.format("{\"name\": \"%s\", \"version\": \"%s\", \"description\": \"%s\", \"suspend\": %s, \"authorization\": { \"classification\": \"%s\", ",
this.getFeedName(),
this.getFeedVersion(),
this.getFeedDescription(),
@@ -264,8 +261,7 @@ public class Feed extends DmaapObject {
}
public static String getSubProvURL( String feedId ) {
- String ret = new DmaapService().getDmaap().getDrProvUrl() + "/subscribe/" + feedId ;
- return ret;
+ return new DmaapService().getDmaap().getDrProvUrl() + "/subscribe/" + feedId;
}
@Override