Add a unit test case for the synchronization provider receive status. The ...

coulbeck

19.35.2007 d00ae6eb8ebca2516ab0543ee5d5b37d17befee3

 opends/src/server/org/opends/server/synchronization/plugin/SynchronizationDomain.java

@@ -431,6 +431,13 @@
        {
          /* was enabled and moved to disabled */
          broker.suspendReceive();
          // FIXME Need a way to stop these threads.
          // Setting the shutdown flag does not stop them until they have
          // consumed and discarded one more message each.
//          for (ListenerThread thread : synchroThreads)
//          {
//            thread.shutdown();
//          }
          synchroThreads.clear();
        }
        receiveStatus = newReceiveStatus;
@@ -1012,7 +1019,7 @@
     * TODO : need to make number of thread configurable
     * TODO : need to handle operation dependencies
     */
    for (int i=0; i<10; i++)
    for (int i=0; i<listenerThreadNumber; i++)
    {
      ListenerThread myThread = new ListenerThread(this);
      myThread.start();