X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdatarouter%2Fprovisioning%2FPoker.java;h=6cb8520d00e0a3e8a9badefe3f42da14a50c1929;hb=c466fbd0026bfc715b4f51854186c62625e8cb61;hp=b9d5e7a6e411741eebd06b3e6555888e452fc8ed;hpb=b60213dc26540543f500b3442b061565907c3cf8;p=dmaap%2Fdatarouter.git diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/Poker.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/Poker.java index b9d5e7a6..6cb8520d 100644 --- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/Poker.java +++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/Poker.java @@ -66,6 +66,7 @@ public class Poker extends TimerTask { private static final String POKE_URL_TEMPLATE = "http://%s/internal/fetchProv"; private static final Object lock = new Object(); + private static final String CARRIAGE_RETURN = "\n],\n"; /** * This is a singleton -- there is only one Poker object in the server @@ -77,6 +78,7 @@ public class Poker extends TimerTask { private EELFLogger logger; private String provString; + private Poker() { timer1 = timer2 = 0; Timer rolex = new Timer(); @@ -84,8 +86,8 @@ public class Poker extends TimerTask { try { thisPod = InetAddress.getLocalHost().getHostName(); } catch (UnknownHostException e) { - thisPod = "*UNKNOWN*"; // not a major problem - logger.info("UnknownHostException: Setting thisPod to \"*UNKNOWN*\""); + thisPod = "*UNKNOWN_POD*"; // not a major problem + logger.info("UnknownHostException: Setting thisPod to \"*UNKNOWN_POD*\"", e); } provString = buildProvisioningString(); @@ -195,10 +197,10 @@ public class Poker extends TimerTask { } catch (MalformedURLException e) { logger.warn( "PROV0013 MalformedURLException Error poking node at " + nodeUrl + " : " + e - .getMessage()); + .getMessage(), e); } catch (IOException e) { logger.warn("PROV0013 IOException Error poking node at " + nodeUrl + " : " + e - .getMessage()); + .getMessage(), e); } }; r.run(); @@ -215,7 +217,7 @@ public class Poker extends TimerTask { sb.append(f.asJSONObject().toString()); pfx = ",\n"; } - sb.append("\n],\n"); + sb.append(CARRIAGE_RETURN); //Append groups to the string - Rally:US708115 - 1610 pfx = "\n"; @@ -225,7 +227,7 @@ public class Poker extends TimerTask { sb.append(s.asJSONObject().toString()); pfx = ",\n"; } - sb.append("\n],\n"); + sb.append(CARRIAGE_RETURN); // Append Subscriptions to the string pfx = "\n"; @@ -237,13 +239,13 @@ public class Poker extends TimerTask { } pfx = ",\n"; } - sb.append("\n],\n"); + sb.append(CARRIAGE_RETURN); // Append Parameters to the string pfx = "\n"; sb.append("\"parameters\": {"); Map props = Parameters.getParameters(); - Set ivals = new HashSet(); + Set ivals = new HashSet<>(); String intv = props.get("_INT_VALUES"); if (intv != null) { ivals.addAll(Arrays.asList(intv.split("\\|"))); @@ -280,7 +282,7 @@ public class Poker extends TimerTask { sb.append(in.asJSONObject().toString()); pfx = ",\n"; } - sb.append("\n],\n"); + sb.append(CARRIAGE_RETURN); pfx = "\n"; sb.append("\"egress\": {");