mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

Jean-Noel Rouvignac
08.48.2015 a89f7014aeb71dba5c94404dfea7eb89e7eeee74
opendj-server-legacy/src/main/java/org/opends/server/loggers/AsynchronousTextWriter.java
@@ -76,7 +76,7 @@
    this.autoFlush = autoFlush;
    this.writer = writer;
    this.queue = new LinkedBlockingQueue<String>(capacity);
    this.queue = new LinkedBlockingQueue<>(capacity);
    this.capacity = capacity;
    this.writerThread = null;
    this.stopRequested = new AtomicBoolean(false);
@@ -105,7 +105,7 @@
    @Override
    public void run()
    {
      ArrayList<String> drainList = new ArrayList<String>(capacity);
      ArrayList<String> drainList = new ArrayList<>(capacity);
      String message = null;
      while (!stopRequested.get() || !queue.isEmpty()) {