public synchronized void stop()

in flume-kudu-sink/src/main/java/org/apache/flume/sink/kudu/KuduSink.java [155:180]

• 25 lines of code
• 5 McCabe index (conditional complexity)

  public synchronized void stop() {
    Exception ex = null;
    try {
      operationsProducer.close();
    } catch (Exception e) {
      ex = e;
      logger.error("Error closing operations producer", e);
    }
    try {
      if (client != null) {
        client.shutdown();
      }
    } catch (Exception e) {
      ex = e;
      logger.error("Error closing client", e);
    }
    client = null;
    table = null;
    session = null;

    sinkCounter.incrementConnectionClosedCount();
    sinkCounter.stop();
    if (ex != null) {
      throw new FlumeException("Error stopping sink", ex);
    }
  }