X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-rest-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fsal%2Frest%2Fimpl%2FJsonToCompositeNodeProvider.java;h=dea4a73cd17d23f53f7c88d9b2ace669b285a2a6;hp=cc6d449523671cfdca429ea1bb31779726a57b9c;hb=d490a11b531a724b9f46ca931b2c98e9527dde7f;hpb=71122c533df3457035350b561362f5601d171780 diff --git a/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/rest/impl/JsonToCompositeNodeProvider.java b/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/rest/impl/JsonToCompositeNodeProvider.java index cc6d449523..dea4a73cd1 100644 --- a/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/rest/impl/JsonToCompositeNodeProvider.java +++ b/opendaylight/md-sal/sal-rest-connector/src/main/java/org/opendaylight/controller/sal/rest/impl/JsonToCompositeNodeProvider.java @@ -11,6 +11,7 @@ import javax.ws.rs.Consumes; import javax.ws.rs.WebApplicationException; import javax.ws.rs.core.MediaType; import javax.ws.rs.core.MultivaluedMap; +import javax.ws.rs.core.Response; import javax.ws.rs.ext.MessageBodyReader; import javax.ws.rs.ext.Provider; @@ -21,7 +22,7 @@ import org.opendaylight.yangtools.yang.data.api.CompositeNode; @Consumes({API+RestconfService.JSON}) public enum JsonToCompositeNodeProvider implements MessageBodyReader { INSTANCE; - + @Override public boolean isReadable(Class type, Type genericType, Annotation[] annotations, MediaType mediaType) { return true; @@ -31,8 +32,13 @@ public enum JsonToCompositeNodeProvider implements MessageBodyReader type, Type genericType, Annotation[] annotations, MediaType mediaType, MultivaluedMap httpHeaders, InputStream entityStream) throws IOException, WebApplicationException { - // TODO Auto-generated method stub - return null; + JsonReader jsonReader = new JsonReader(); + try { + return jsonReader.read(entityStream); + } catch (UnsupportedFormatException e) { + throw new WebApplicationException(e,Response.status(Response.Status.BAD_REQUEST) + .entity(e.getMessage()).build()); + } } }