diff options
Diffstat (limited to 'PolicyEngineAPI/src/main/java/org/openecomp/policy/std/ManualClientEndUEB.java')
-rw-r--r-- | PolicyEngineAPI/src/main/java/org/openecomp/policy/std/ManualClientEndUEB.java | 22 |
1 files changed, 7 insertions, 15 deletions
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 b1962bc77..398e8d51f 100644 --- a/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/ManualClientEndUEB.java +++ b/PolicyEngineAPI/src/main/java/org/openecomp/policy/std/ManualClientEndUEB.java @@ -22,36 +22,33 @@ package org.openecomp.policy.std; import java.io.IOException; import java.net.MalformedURLException; -import java.net.URI; -import java.net.URISyntaxException; import java.net.URL; import java.security.GeneralSecurityException; import java.util.List; -import java.util.UUID; -import java.util.concurrent.CountDownLatch; -//import org.apache.log4j.Logger; import org.json.JSONObject; import org.openecomp.policy.api.NotificationScheme; import org.openecomp.policy.api.NotificationType; import org.openecomp.policy.api.PDPNotification; -import org.openecomp.policy.std.StdPDPNotification; +import org.openecomp.policy.common.logging.flexlogger.FlexLogger; +import org.openecomp.policy.common.logging.flexlogger.Logger; import com.att.nsa.cambria.client.CambriaClientFactory; import com.att.nsa.cambria.client.CambriaConsumer; -import com.att.nsa.cambria.client.CambriaPublisher; -import com.fasterxml.jackson.core.JsonParseException; -import com.fasterxml.jackson.databind.JsonMappingException; -import org.openecomp.policy.common.logging.flexlogger.*; +import com.att.nsa.cambria.client.CambriaPublisher; +@SuppressWarnings("deprecation") public class ManualClientEndUEB { private static StdPDPNotification notification = null; private static String resultJson = null; private static Logger logger = FlexLogger.getLogger(ManualClientEndUEB.class.getName()); private static CambriaConsumer CConsumer = null; + @SuppressWarnings("unused") private static List<String> uebURLList = null; + @SuppressWarnings("unused") private static boolean messageNotReceived = false; + @SuppressWarnings("unused") private static String url = null; private static String uniquID = null; private static String topic = null; @@ -94,10 +91,8 @@ public class ManualClientEndUEB { try { pub = CambriaClientFactory.createSimplePublisher(null, UEBlist, pubTopic); } catch (MalformedURLException e1) { - // TODO Auto-generated catch block e1.printStackTrace(); } catch (GeneralSecurityException e1) { - // TODO Auto-generated catch block e1.printStackTrace(); } final JSONObject msg1 = new JSONObject (); @@ -107,7 +102,6 @@ public class ManualClientEndUEB { try { pub.send ( "MyPartitionKey", msg1.toString () ); } catch (IOException e) { - // TODO Auto-generated catch block e.printStackTrace(); } pub.close (); @@ -142,10 +136,8 @@ public class ManualClientEndUEB { try { CConsumer = CambriaClientFactory.createConsumer ( null, uebURLList, topic + uniquID, "clientGroup", id, 15*1000, 1000 ); } catch (MalformedURLException e1) { - // TODO Auto-generated catch block e1.printStackTrace(); } catch (GeneralSecurityException e1) { - // TODO Auto-generated catch block e1.printStackTrace(); } int count = 1; |