public void close() {
      synchronized (this) {
        timeToStop = true;
        flushNeeded = true;
        notifyAll();
      }
    }
Called when a message writer needs the current fillBatchBuffer flushed
geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java