X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=main%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fpolicy%2Fpdpx%2Fmain%2Fcomm%2FXacmlPdpUpdatePublisher.java;h=54d9cf65990b97e31d4a90fa2b55c2698de3d4ce;hb=ae182a04e4bf5c05bebcefe71d1fd000363aab09;hp=4c9d0c215f37c63da08e066ec70e46d53700f233;hpb=72437db96093801ebef94d22418cd2e7a86a08f2;p=policy%2Fxacml-pdp.git diff --git a/main/src/main/java/org/onap/policy/pdpx/main/comm/XacmlPdpUpdatePublisher.java b/main/src/main/java/org/onap/policy/pdpx/main/comm/XacmlPdpUpdatePublisher.java index 4c9d0c21..54d9cf65 100644 --- a/main/src/main/java/org/onap/policy/pdpx/main/comm/XacmlPdpUpdatePublisher.java +++ b/main/src/main/java/org/onap/policy/pdpx/main/comm/XacmlPdpUpdatePublisher.java @@ -44,7 +44,8 @@ public class XacmlPdpUpdatePublisher { * @param message Incoming message * @param client TopicSinkClient */ - public static void handlePdpUpdate(PdpUpdate message, TopicSinkClient client) { + public static void handlePdpUpdate(PdpUpdate message, TopicSinkClient client, + XacmlPdpMessage updatePdpMessage) { if (!message.getPolicies().isEmpty() || message.getPolicies() != null) { @@ -70,8 +71,8 @@ public class XacmlPdpUpdatePublisher { } } - XacmlPdpMessage updatePdpMessage = new XacmlPdpMessage(); - PdpStatus statusMessage = updatePdpMessage.formatPdpUpdateMessage(message, XacmlPdpHearbeatPublisher.pdpState); + updatePdpMessage.updateInternalStatus(message); + PdpStatus statusMessage = updatePdpMessage.formatPdpStatusMessage(); sendPdpUpdate(statusMessage, client); }