refactor: remove dead code #1638

ICIJ · Jan 27, 2025 · adf3b56 · adf3b56
1 parent 1f5a6b5
commit adf3b56
Showing 1 changed file with 0 additions and 12 deletions.
diff --git a/datashare-tasks/src/main/java/org/icij/datashare/asynctasks/bus/amqp/AmqpInterlocutor.java b/datashare-tasks/src/main/java/org/icij/datashare/asynctasks/bus/amqp/AmqpInterlocutor.java
@@ -133,18 +133,6 @@ public void deleteQueues(AmqpQueue... amqpQueues) throws IOException {
         }
     }
 
-    public boolean getHealth() {
-        if (!connection.isOpen()) {
-            logger.error("TaskManager AMQP Health error : Connection is closed");
-            return false;
-        }
-        if (connection.getHeartbeat() <= 0) {
-            logger.error("TaskManager AMQP Health error : heartbeat equals 0");
-            return false;
-        }
-        return true;
-    }
-
     private static class UnknownChannelException extends RuntimeException {
         public UnknownChannelException(AmqpQueue queue) {
             super("Unknown channel for queue " + queue);