AbstractSocketAppender.java

class AbstractSocketAppender extends ... {

  ConnectionRunner connectionRunner = ...:

  public final void run() {
    try {
      while (!Thread.currentThread().isInterrupted()) {
         Socket socket = connectionRunner.getSocket();
         if(socket == null)
           break;
         dispatchEvents();
      }
    } catch (InterruptedException ex) {
      assert true;    // ok... we'll exit now
    }
    addInfo("shutting down");
  }

  void stop() {
    CloseUtil.closeQuietly(socket);
    task.cancel(true);
    connectionRunner.stop();
    super.stop(); 
  }
}