X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdbcapi.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fmodel%2FFeed.java;h=b327f3a4ea806855d240375a225bf67ca756e1be;hp=9f7b3fc87bb0cbc5685afa0e8b97ab585685dfee;hb=503da874ce876dbe463bcc1a03f63ea0f48fe650;hpb=0afd0dd2f1fa4435fa730a287e68fec4f271e617 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 9f7b3fc..b327f3a 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/model/Feed.java +++ b/src/main/java/org/onap/dmaap/dbcapi/model/Feed.java @@ -96,7 +96,7 @@ public class Feed extends DmaapObject { 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 ) { @@ -104,30 +104,50 @@ public class Feed extends DmaapObject { this.setStatus( DmaapObject_Status.INVALID ); return; } + logger.info( "templog:Feed at 11" ); 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.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 = new ArrayList(); + logger.info( "templog:Feed at 28" ); 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"), @@ -135,9 +155,12 @@ public class Feed extends DmaapObject { 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" ); }