X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=holmes-actions%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fholmes%2Fcommon%2Fdmaap%2FPublisher.java;fp=holmes-actions%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fholmes%2Fcommon%2Fdmaap%2FPublisher.java;h=285c3d6fcbe597754bee9a6165dd298bf2d3283b;hb=105437a89bd5bcfcaf40dac25e2c087aafb0996b;hp=035ecaa80e808bf856a31b2685ec289969ef7926;hpb=7b42bb15c5ed414fd465af8c836ae63abb8b21c0;p=holmes%2Fcommon.git diff --git a/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/Publisher.java b/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/Publisher.java index 035ecaa..285c3d6 100644 --- a/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/Publisher.java +++ b/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/Publisher.java @@ -25,6 +25,7 @@ import javax.ws.rs.core.MediaType; import javax.ws.rs.core.Response; import lombok.Getter; import lombok.Setter; +import org.apache.http.HttpStatus; import org.glassfish.jersey.client.ClientConfig; import org.jvnet.hk2.annotations.Service; import org.onap.holmes.common.dmaap.entity.PolicyMsg; @@ -47,17 +48,16 @@ public class Publisher { try { content = mapper.writeValueAsString(msg); } catch (JsonProcessingException e) { - throw new CorrelationException("Failed to convert the message object to a json string.", e); + throw new CorrelationException("Failed to convert the message object to a json string.", + e); } - WebTarget webTarget = client.target(url); Response response = webTarget.request(MediaType.APPLICATION_JSON) .post(Entity.entity(content, MediaType.APPLICATION_JSON)); - return checkStatus(response); } private boolean checkStatus(Response response) { - return false; + return (response.getStatus() == HttpStatus.SC_OK) ? true : false; } }