From 8280d2b7b61920c0bc6311ae97181b28eef9fa44 Mon Sep 17 00:00:00 2001 From: Guangrong Fu Date: Thu, 17 Aug 2017 09:54:46 +0800 Subject: Initialize the publisher Add a new class for the publisher Change-Id: Ie487dfd239b9ebbb2644bae178db949dee02d96f Issue-ID: HOLMES-30 Signed-off-by: Guangrong Fu --- .../org/onap/holmes/common/dmaap/Publisher.java | 62 ++++++++++++++++++++++ 1 file changed, 62 insertions(+) create mode 100644 holmes-actions/src/main/java/org/onap/holmes/common/dmaap/Publisher.java 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 new file mode 100644 index 0000000..eaeaf43 --- /dev/null +++ b/holmes-actions/src/main/java/org/onap/holmes/common/dmaap/Publisher.java @@ -0,0 +1,62 @@ +/* + * Copyright 2017 ZTE Corporation. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.onap.holmes.common.dmaap; + +import com.fasterxml.jackson.core.JsonProcessingException; +import com.fasterxml.jackson.databind.ObjectMapper; +import javax.ws.rs.client.Client; +import javax.ws.rs.client.ClientBuilder; +import javax.ws.rs.client.Entity; +import javax.ws.rs.client.WebTarget; +import javax.ws.rs.core.MediaType; +import javax.ws.rs.core.Response; +import lombok.Getter; +import lombok.Setter; +import org.glassfish.jersey.client.ClientConfig; +import org.onap.holmes.common.dmaap.entity.PolicyMsg; +import org.onap.holmes.common.exception.CorrelationException; + +@Getter +@Setter +public class Publisher { + + private String topic; + private String url; + private String authInfo; + private String authExpDate; + + public boolean publish(PolicyMsg msg) throws CorrelationException { + Client client = ClientBuilder.newClient(new ClientConfig()); + ObjectMapper mapper = new ObjectMapper(); + String content = null; + try { + content = mapper.writeValueAsString(msg); + } catch (JsonProcessingException 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; + } +} -- cgit 1.2.3-korg