From dfbe880eb338a1d752ce790f689b5133761d7079 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Thu, 26 Sep 2013 07:35:55 +0000
Subject: [PATCH] OPENDJ-1116 Introduce abstraction for the changelog DB
---
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java | 14 +++++++-------
1 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java
index 62a90bf..e84cbcc 100644
--- a/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java
+++ b/opends/tests/unit-tests-testng/src/server/org/opends/server/replication/StressTest.java
@@ -27,10 +27,6 @@
*/
package org.opends.server.replication;
-import static org.opends.server.TestCaseUtils.*;
-import static org.opends.server.loggers.ErrorLogger.*;
-import static org.testng.Assert.*;
-
import java.util.LinkedList;
import java.util.List;
@@ -52,6 +48,10 @@
import org.testng.annotations.BeforeClass;
import org.testng.annotations.Test;
+import static org.opends.server.TestCaseUtils.*;
+import static org.opends.server.loggers.ErrorLogger.*;
+import static org.testng.Assert.*;
+
/**
* Stress test for the synchronization code using the ReplicationBroker API.
*/
@@ -80,11 +80,11 @@
logError(Message.raw(Category.SYNC, Severity.NOTICE,
"Starting replication StressTest : fromServertoBroker"));
- final DN baseDn = DN.decode("ou=People," + TEST_ROOT_DN_STRING);
+ final DN baseDN = DN.decode("ou=People," + TEST_ROOT_DN_STRING);
final int TOTAL_MESSAGES = 1000;
ReplicationBroker broker =
- openReplicationSession(baseDn, 18, 100, replServerPort, 5000, true);
+ openReplicationSession(baseDN, 18, 100, replServerPort, 5000, true);
Monitor monitor = new Monitor();
DirectoryServer.registerMonitorProvider(monitor);
@@ -117,7 +117,7 @@
assertTrue(OperationType.ADD.compareTo(receivedOp.getOperationType()) == 0,
"The received replication message is not an ADD msg");
- assertEquals(DN.decode(addMsg.getDn()),personEntry.getDN(),
+ assertEquals(addMsg.getDN(), personEntry.getDN(),
"The received ADD replication message is not for the excepted DN");
}
--
Gitblit v1.10.0