Merge pull request #166 from scippacercola/main

fix: logging of connection failures due to bad evaluation of a string…
conductor-oss · Jul 1, 2024 · 896a12e · 896a12e
2 parents 0c92193 + 0c52c4b
commit 896a12e
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...-persistence/src/main/java/com/netflix/conductor/postgres/util/PostgresQueueListener.java b/...-persistence/src/main/java/com/netflix/conductor/postgres/util/PostgresQueueListener.java
@@ -166,7 +166,7 @@ private void requestStats() {
                 conn.setAutoCommit(previousAutoCommitMode);
             }
         } catch (SQLException e) {
-            if (!e.getSQLState().equals("08003")) {
+            if (!isSQLExceptionConnectionDoesNotExists(e)) {
                 logger.error("Error fetching notifications {}", e.getSQLState());
             }
             connect();
@@ -187,7 +187,7 @@ private void handleNotifications() {
             }
             processPayload(notifications[notifications.length - 1].getParameter());
         } catch (SQLException e) {
-            if (e.getSQLState() != "08003") {
+            if (!isSQLExceptionConnectionDoesNotExists(e)) {
                 logger.error("Error fetching notifications {}", e.getSQLState());
             }
             connect();
@@ -223,4 +223,8 @@ private void processPayload(String payload) {
             throw new RuntimeException(e);
         }
     }
+
+    private static boolean isSQLExceptionConnectionDoesNotExists(SQLException e) {
+        return "08003".equals(e.getSQLState());
+    }
 }