X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=PolicyEngineAPI%2Fsrc%2Fmain%2Fjava%2Forg%2Fopenecomp%2Fpolicy%2Fstd%2FManualClientEndUEB.java;h=85d5659e82fcfb73fcf1b58a4693147321ba6944;hb=685ed1545ed28b777a3ba6e7d315b78f355154cb;hp=287e5c8511bc3addc79a6a6bc891aa7ca36457a4;hpb=fc5c07705edc4dcb7083b39116a43844bb6a1490;p=policy%2Fengine.git diff --git a/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/ManualClientEndUEB.java b/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/ManualClientEndUEB.java index 287e5c851..85d5659e8 100644 --- a/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/ManualClientEndUEB.java +++ b/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/ManualClientEndUEB.java @@ -95,14 +95,14 @@ public class ManualClientEndUEB { final JSONObject msg1 = new JSONObject (); msg1.put ( "JSON", "UEB Update Ruest UID=" + uniqueID); - - try { - pub.send ( "MyPartitionKey", msg1.toString () ); - } catch (IOException e) { - logger.error("Exception Occured"+e); - } - pub.close (); - + if(pub != null){ + try { + pub.send ( "MyPartitionKey", msg1.toString () ); + pub.close (); + } catch (IOException e) { + logger.error("Exception Occured"+e); + } + } } public static void createTopic (String url, String uniquID, List uebURLList){