| | |
| | | import org.testng.annotations.Test; |
| | | |
| | | import static org.mockito.Mockito.*; |
| | | import static org.opends.server.TestCaseUtils.*; |
| | | import static org.opends.server.util.CollectionUtils.*; |
| | | import static org.testng.Assert.*; |
| | | |
| | | /** |
| | |
| | | private ReplicationBroker createReplicationBroker(int dsId, |
| | | ServerState state, long generationId) throws Exception |
| | | { |
| | | SortedSet<String> replServers = newSortedSet("localhost:" + rs1Port); |
| | | SortedSet<String> replServers = newTreeSet("localhost:" + rs1Port); |
| | | DomainFakeCfg fakeCfg = new DomainFakeCfg(EXAMPLE_DN_, dsId, replServers); |
| | | fakeCfg.setHeartbeatInterval(0); |
| | | fakeCfg.setChangetimeHeartbeatInterval(500); |