docs: public void sendAllMessage() {
      if (!isConnected()) {
        return;
      }
  
      LOG.info("Flushing all pending data in MetricsManagerClient");
      // Collect all tuples in queue
      for (Communicator<Metrics.MetricPublisherPublishMessage> c : outMetricsQueues) {
        int size = c.size();
        for (int i = 0; i < size; i++) {
          Metrics.MetricPublisherPublishMessage m = c.poll();
          sendMessage(m);
        }
      }
    }