X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdbcapi.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fresources%2FTopicResource.java;h=822181376ffc4a1f42f543481050aced39ccd140;hp=0f99fb624d5a824e288bca9de1fd3d5c873768fe;hb=0ab116b376402b076b2b8558dedc8e6f88d1a2d5;hpb=6349f10fcf1902c1f41ec58c26e57dd11ea3b78f diff --git a/src/main/java/org/onap/dmaap/dbcapi/resources/TopicResource.java b/src/main/java/org/onap/dmaap/dbcapi/resources/TopicResource.java index 0f99fb6..8221813 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/resources/TopicResource.java +++ b/src/main/java/org/onap/dmaap/dbcapi/resources/TopicResource.java @@ -44,9 +44,11 @@ import org.onap.dmaap.dbcapi.logging.BaseLoggingClass; import org.onap.dmaap.dbcapi.model.ApiError; import org.onap.dmaap.dbcapi.model.DR_Pub; import org.onap.dmaap.dbcapi.model.ReplicationType; +import org.onap.dmaap.dbcapi.model.FqtnType; import org.onap.dmaap.dbcapi.model.Topic; import org.onap.dmaap.dbcapi.service.ApiService; import org.onap.dmaap.dbcapi.service.TopicService; +import org.onap.dmaap.dbcapi.util.DmaapConfig; @Path("/topics") @Api( value= "topics", description = "Endpoint for retreiving MR Topics" ) @@ -54,8 +56,14 @@ import org.onap.dmaap.dbcapi.service.TopicService; @Produces(MediaType.APPLICATION_JSON) @Authorization public class TopicResource extends BaseLoggingClass { - + private static FqtnType defaultTopicStyle; TopicService mr_topicService = new TopicService(); + + public TopicResource() { + DmaapConfig p = (DmaapConfig)DmaapConfig.getConfig(); + defaultTopicStyle = FqtnType.Validator( p.getProperty("MR.topicStyle", "FQTN_LEGACY_FORMAT")); + logger.info( "Setting defaultTopicStyle=" + defaultTopicStyle ); + } @GET @ApiOperation( value = "return Topic details", @@ -104,7 +112,11 @@ public class TopicResource extends BaseLoggingClass { if ( t == null || t == ReplicationType.REPLICATION_NOT_SPECIFIED ) { topic.setReplicationCase( mr_topicService.reviewTopic(topic)); } - + FqtnType ft = topic.getFqtnStyle(); + if ( ft == null || ft == FqtnType.FQTN_NOT_SPECIFIED ) { + logger.info( "setting defaultTopicStyle=" + defaultTopicStyle + " for topic " + topic.getTopicName() ); + topic.setFqtnStyle( defaultTopicStyle ); + } topic.setLastMod(); Topic mrc = mr_topicService.addTopic(topic, check.getErr());