@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();
return resp.error();
}
+
FeedService feedService = new FeedService();
Feed nfeed = feedService.getFeedByName( feed.getFeedName(), feed.getFeedVersion(), resp.getErr() );
if ( nfeed == null ) {
return resp.error();
}
} else if ( nfeed.getStatus() == DmaapObject_Status.DELETED ) {
- nfeed = feedService.updateFeed(nfeed, resp.getErr());
+ feed.setFeedId( nfeed.getFeedId());
+ nfeed = feedService.updateFeed(feed, resp.getErr());
if ( nfeed != null ) {
return resp.success(nfeed);
} else {
return resp.error();
}
+ } else if ( (useExisting != null) && ("true".compareToIgnoreCase( useExisting ) == 0)) {
+ return resp.success(nfeed);
}
resp.setCode(Status.CONFLICT.getStatusCode());