X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdatarouter.git;a=blobdiff_plain;f=datarouter-prov%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdatarouter%2Fprovisioning%2Fbeans%2FEgressRoute.java;h=e766e7048e59374f29fde840874e86624c61f87f;hp=1213596997815b59f6839e4e8e0dc3b4eb902129;hb=refs%2Fchanges%2F55%2F87355%2F1;hpb=bb01feceff0527c8f63ad513d85975e5c4e2e52f diff --git a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/EgressRoute.java b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/EgressRoute.java index 12135969..e766e704 100644 --- a/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/EgressRoute.java +++ b/datarouter-prov/src/main/java/org/onap/dmaap/datarouter/provisioning/beans/EgressRoute.java @@ -47,6 +47,7 @@ import org.onap.dmaap.datarouter.provisioning.utils.DB; public class EgressRoute extends NodeClass implements Comparable { private static EELFLogger intlogger = EELFManager.getInstance().getLogger("InternalLog"); + private static final String SQLEXCEPTION = "SQLException: "; private final int subid; private final int nodeid; @@ -57,7 +58,7 @@ public class EgressRoute extends NodeClass implements Comparable { * @return the sorted set */ public static SortedSet getAllEgressRoutes() { - SortedSet set = new TreeSet(); + SortedSet set = new TreeSet<>(); try { DB db = new DB(); @SuppressWarnings("resource") @@ -74,7 +75,7 @@ public class EgressRoute extends NodeClass implements Comparable { db.release(conn); } catch (SQLException e) { - intlogger.error("SQLException " + e.getMessage()); + intlogger.error("PROV0008 EgressRoute.getAllEgressRoutes: " + e.getMessage(), e); } return set; } @@ -104,20 +105,20 @@ public class EgressRoute extends NodeClass implements Comparable { ps.close(); db.release(conn); } catch (SQLException e) { - intlogger.error("SQLException " + e.getMessage()); + intlogger.error("PROV0009 EgressRoute.getEgressRoute: " + e.getMessage(), e); } finally { try { if (ps != null) { ps.close(); } } catch (SQLException e) { - intlogger.error("SQLException " + e.getMessage()); + intlogger.error(SQLEXCEPTION + e.getMessage(), e); } } return v; } - public EgressRoute(int subid, int nodeid) throws IllegalArgumentException { + public EgressRoute(int subid, int nodeid) { this.subid = subid; this.nodeid = nodeid; // Note: unlike for Feeds, it subscriptions can be removed from the tables, so it is @@ -126,7 +127,7 @@ public class EgressRoute extends NodeClass implements Comparable { // throw new IllegalArgumentException("No such subscription: "+subid); } - public EgressRoute(int subid, String node) throws IllegalArgumentException { + public EgressRoute(int subid, String node) { this(subid, lookupNodeName(node)); } @@ -141,15 +142,14 @@ public class EgressRoute extends NodeClass implements Comparable { ps.execute(); } catch (SQLException e) { rv = false; - intlogger.warn("PROV0007 doDelete: " + e.getMessage()); - intlogger.error("SQLException " + e.getMessage()); + intlogger.error("PROV0007 doDelete: " + e.getMessage(), e); } finally { try { if (ps != null) { ps.close(); } } catch (SQLException e) { - intlogger.error("SQLException " + e.getMessage()); + intlogger.error(SQLEXCEPTION + e.getMessage(), e); } } return rv; @@ -169,14 +169,14 @@ public class EgressRoute extends NodeClass implements Comparable { ps.close(); rv = true; } catch (SQLException e) { - intlogger.warn("PROV0005 doInsert: " + e.getMessage()); + intlogger.warn("PROV0005 doInsert: " + e.getMessage(), e); } finally { try { if (ps != null) { ps.close(); } } catch (SQLException e) { - intlogger.error("SQLException " + e.getMessage()); + intlogger.error(SQLEXCEPTION + e.getMessage(), e); } } return rv; @@ -194,14 +194,14 @@ public class EgressRoute extends NodeClass implements Comparable { ps.executeUpdate(); } catch (SQLException e) { rv = false; - intlogger.warn("PROV0006 doUpdate: " + e.getMessage()); + intlogger.warn("PROV0006 doUpdate: " + e.getMessage(), e); } finally { try { if (ps != null) { ps.close(); } } catch (SQLException e) { - intlogger.error("SQLException " + e.getMessage()); + intlogger.error(SQLEXCEPTION + e.getMessage(), e); } } return rv;