* org.onap.dmaap
* ================================================================================
* Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
+ *
+ * Modifications Copyright (C) 2019 IBM.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
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();
JSONObject jsonObj;
- logger.info( "templog:Feed at 10" );
try {
jsonObj = (JSONObject) parser.parse( json );
} catch ( ParseException pe ) {
- logger.error( "Error parsing provisioning data: " + json );
- this.setStatus( DmaapObject_Status.INVALID );
- return;
- }
- logger.info( "templog:Feed at 11" );
+ logger.error( "Error parsing provisioning data: " + json );
+ this.setStatus( DmaapObject_Status.INVALID );
+ return;
+ }
this.setFeedName( (String) jsonObj.get("name"));
- logger.info( "templog:Feed at 12" );
-
this.setFeedVersion( (String) jsonObj.get("version"));
- logger.info( "templog:Feed at 13" );
this.setFeedDescription( (String) jsonObj.get("description"));
- logger.info( "templog:Feed at 14" );
this.setOwner( (String) jsonObj.get("publisher"));
- logger.info( "templog:Feed at 15" );
this.setSuspended( (boolean) jsonObj.get("suspend"));
- logger.info( "templog:Feed at 16" );
JSONObject links = (JSONObject) jsonObj.get("links");
- logger.info( "templog:Feed at 17" );
String url = (String) links.get("publish");
- logger.info( "templog:Feed at 18" );
this.setPublishURL( url );
- logger.info( "templog:Feed at 19" );
this.setFeedId( url.substring( url.lastIndexOf('/')+1, url.length() ));
- logger.info( "templog:Feed at 20" );
logger.info( "feedid="+ this.getFeedId() );
- logger.info( "templog:Feed at 21" );
- this.setSubscribeURL( (String) links.get("subscribe") );
- logger.info( "templog:Feed at 22" );
+ this.setSubscribeURL( (String) links.get("subscribe") );
this.setLogURL( (String) links.get("log") );
- logger.info( "templog:Feed at 23" );
JSONObject auth = (JSONObject) jsonObj.get("authorization");
- logger.info( "templog:Feed at 24" );
this.setAsprClassification( (String) auth.get("classification"));
- logger.info( "templog:Feed at 25" );
JSONArray pubs = (JSONArray) auth.get( "endpoint_ids");
- logger.info( "templog:Feed at 26" );
int i;
- logger.info( "templog:Feed at 27" );
- ArrayList<DR_Pub> dr_pub = new ArrayList<DR_Pub>();
- logger.info( "templog:Feed at 28" );
- this.subs = new ArrayList<DR_Sub>();
+ ArrayList<DR_Pub> dr_pub = new ArrayList<>();
+ this.subs = new ArrayList<>();
for( i = 0; i < pubs.size(); i++ ) {
- logger.info( "templog:Feed at 29 " + i );
JSONObject entry = (JSONObject) pubs.get(i);
- logger.info( "templog:Feed at 30" );
- 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() ));
+
}
- logger.info( "templog:Feed at 31" );
this.setPubs( dr_pub );
-
- logger.info( "templog:Feed at 32" );
+
this.setStatus( DmaapObject_Status.VALID );
- logger.info( "templog:Feed at 33" );
}
+
+
+ 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;
}
// 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(),
}
public static String getSubProvURL( String feedId ) {
- String ret = new String();
- ret = new DmaapService().getDmaap().getDrProvUrl() + "/subscribe/" + feedId ;
- return ret;
+ return new DmaapService().getDmaap().getDrProvUrl() + "/subscribe/" + feedId;
}
@Override
Code Review / dmaap / dbcapi.git / blobdiff