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
index 06a58647a..e05064343 100644
--- 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);