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

gbellato
29.27.2007 a6be5db964ffa77a68b91966d99f6fa0b36b532e
opends/src/server/org/opends/server/replication/plugin/ReplicationDomain.java
@@ -126,6 +126,12 @@
   */
  private static final DebugTracer TRACER = getTracer();
  /**
   * on shutdown, the server will wait for existing threads to stop
   * during this timeout (in ms).
   */
  private static final int SHUTDOWN_JOIN_TIMEOUT = 30000;
  private ReplicationMonitor monitor;
  private ReplicationBroker broker;
@@ -1047,6 +1053,12 @@
    // stop the ReplicationBroker
    broker.stop();
    //  wait for the listener thread to stop
    for (ListenerThread thread : synchroThreads)
    {
      thread.shutdown();
    }
  }
  /**
@@ -1745,6 +1757,17 @@
      thread.shutdown();
    }
    broker.stop(); // this will cut the session and wake-up the listeners
    for (ListenerThread thread : synchroThreads)
    {
      try
      {
        thread.join(SHUTDOWN_JOIN_TIMEOUT);
      } catch (InterruptedException e)
      {
        // ignore
      }
    }
  }
  /**