X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fresources%2FFeedResource.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fresources%2FFeedResource.java;h=97336c1a96ec8bf62f4d67da518a91ba422c1a80;hb=87bf9245434ad317ea39a84a0099233197f3d7c2;hp=c0fdd0d93b19ad9bed09deec6a4f611fc5714113;hpb=ebdb8b74c1d10e4bdc477c0f5e61311a9bfd9ead;p=dmaap%2Fdbcapi.git diff --git a/src/main/java/org/onap/dmaap/dbcapi/resources/FeedResource.java b/src/main/java/org/onap/dmaap/dbcapi/resources/FeedResource.java index c0fdd0d..97336c1 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/resources/FeedResource.java +++ b/src/main/java/org/onap/dmaap/dbcapi/resources/FeedResource.java @@ -100,7 +100,8 @@ public class FeedResource extends BaseLoggingClass { @ApiResponse( code = 400, message = "Error", response = ApiError.class ) }) public Response addFeed( - @WebParam(name = "feed") Feed feed + @WebParam(name = "feed") Feed feed, + @QueryParam("useExisting") String useExisting ) { ApiService resp = new ApiService(); @@ -115,6 +116,7 @@ public class FeedResource extends BaseLoggingClass { return resp.error(); } + FeedService feedService = new FeedService(); Feed nfeed = feedService.getFeedByName( feed.getFeedName(), feed.getFeedVersion(), resp.getErr() ); if ( nfeed == null ) { @@ -136,6 +138,8 @@ public class FeedResource extends BaseLoggingClass { return resp.error(); } + } else if ( (useExisting != null) && ("true".compareToIgnoreCase( useExisting ) == 0)) { + return resp.success(nfeed); } resp.setCode(Status.CONFLICT.getStatusCode());