| | |
| | | |
| | | import static org.opends.messages.ReplicationMessages.*; |
| | | import static org.opends.server.TestCaseUtils.*; |
| | | import static org.opends.server.util.CollectionUtils.*; |
| | | import static org.testng.Assert.*; |
| | | |
| | | import java.util.Arrays; |
| | | import java.util.Map; |
| | | import java.util.SortedSet; |
| | | import java.util.TreeSet; |
| | | import java.util.concurrent.BlockingQueue; |
| | | import java.util.concurrent.LinkedBlockingQueue; |
| | | import java.util.concurrent.TimeUnit; |
| | |
| | | int replicationPort, String dirName, int windowSize, |
| | | String... replServers) throws Exception |
| | | { |
| | | return createReplicationServer(serverId, replicationPort, dirName, |
| | | windowSize, new TreeSet<String>(Arrays.asList(replServers))); |
| | | return createReplicationServer(serverId, replicationPort, dirName, windowSize, newTreeSet(replServers)); |
| | | } |
| | | |
| | | private ReplicationServer createReplicationServer(int serverId, |