X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=ECOMP-PDP-REST%2Fsrc%2Fmain%2Fjava%2Forg%2Fopenecomp%2Fpolicy%2Fpdp%2Frest%2Fnotifications%2FNotificationServer.java;h=21fb8f3c9b1497852e4a6f1172e601eccfcb3cc2;hb=685ed1545ed28b777a3ba6e7d315b78f355154cb;hp=136f222684e0e3ea1c24debed463bb08d59a38fb;hpb=fc5c07705edc4dcb7083b39116a43844bb6a1490;p=policy%2Fengine.git

diff --git a/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/notifications/NotificationServer.java b/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/notifications/NotificationServer.java
index 136f22268..21fb8f3c9 100644
--- a/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/notifications/NotificationServer.java
+++ b/ECOMP-PDP-REST/src/main/java/org/openecomp/policy/pdp/rest/notifications/NotificationServer.java
@@ -143,27 +143,26 @@ public class NotificationServer {
 			} catch (GeneralSecurityException e1) {
 				LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error creating the UEB publisher" + e1.getMessage());
 			}
-
-			try {
-				pub.send( "MyPartitionKey", notification );
-			} catch (IOException e) {
-				LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error sending notification update" + e.getMessage());
-			}
-			
-			// close the publisher. The batching publisher does not send events
-			// immediately, so you MUST use close to send any remaining messages.
-			// You provide the amount of time you're willing to wait for the sends
-			// to succeed before giving up. If any messages are unsent after that time,
-			// they're returned to your app. You could, for example, persist to disk
-			// and try again later.
-			final List<?> stuck = pub.close ( 20, TimeUnit.SECONDS );
-			
-			if ( stuck.size () > 0 ){
-				LOGGER.error( stuck.size() + " messages unsent" );
-			}else{
-				LOGGER.info( "Clean exit; all messages sent: " + notification );
+			if(pub != null){
+				try {
+					pub.send( "MyPartitionKey", notification );
+				} catch (IOException e) {
+					LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + "Error sending notification update" + e.getMessage() + e);
+				}
+				// close the publisher. The batching publisher does not send events
+				// immediately, so you MUST use close to send any remaining messages.
+				// You provide the amount of time you're willing to wait for the sends
+				// to succeed before giving up. If any messages are unsent after that time,
+				// they're returned to your app. You could, for example, persist to disk
+				// and try again later.
+				final List<?> stuck = pub.close ( 20, TimeUnit.SECONDS );
+				
+				if (!stuck.isEmpty()){
+					LOGGER.error( stuck.size() + " messages unsent" );
+				}else{
+					LOGGER.info( "Clean exit; all messages sent: " + notification );
+				}
 			}
-			
 		} else if (propNotificationType.equals("dmaap")) {
 			
 			// Setting up the Publisher for DMaaP MR