| | |
| | | import org.opends.server.replication.protocol.UpdateMsg; |
| | | import org.opends.server.replication.server.ReplServerFakeConfiguration; |
| | | import org.opends.server.replication.server.ReplicationServer; |
| | | import org.opends.server.replication.server.changelog.api.ChangelogException; |
| | | import org.opends.server.replication.server.changelog.api.DBCursor; |
| | | import org.opends.server.types.DN; |
| | | import org.opends.server.util.StaticUtils; |
| | |
| | | } |
| | | } |
| | | |
| | | private void assertNotFound(JEReplicaDB replicaDB, CSN csn) |
| | | private void assertNotFound(JEReplicaDB replicaDB, CSN csn) throws Exception |
| | | { |
| | | DBCursor<UpdateMsg> cursor = null; |
| | | try |
| | | { |
| | | cursor = replicaDB.generateCursorFrom(csn); |
| | | fail("Expected exception"); |
| | | } |
| | | catch (ChangelogException e) |
| | | { |
| | | assertEquals(e.getLocalizedMessage(), "CSN not available"); |
| | | assertFalse(cursor.next()); |
| | | assertNull(cursor.getRecord()); |
| | | } |
| | | finally |
| | | { |