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

Jean-Noel Rouvignac
08.06.2015 b8c6b80da1cb6118167a934daa480eb381c59e0e
opendj-server-legacy/src/test/java/org/opends/server/replication/StressTest.java
@@ -267,7 +267,9 @@
        {
          ReplicationMsg msg = broker.receive();
          if (msg == null)
          {
            break;
          }
          count ++;
        }
      } catch (Exception e)
@@ -318,10 +320,13 @@
    {
      Attribute attr;
      if (reader == null)
      {
        attr = Attributes.create("received-messages", "not yet started");
      }
      else
        attr = Attributes.create("received-messages", String
            .valueOf(reader.getCurrentCount()));
      {
        attr = Attributes.create("received-messages", String.valueOf(reader.getCurrentCount()));
      }
      List<Attribute> list = new LinkedList<>();
      list.add(attr);
      attr = Attributes.create("base-dn", "ou=People," + TEST_ROOT_DN_STRING);