| | |
| | | */ |
| | | package org.opends.server.replication.server; |
| | | |
| | | import static org.forgerock.opendj.ldap.ModificationType.*; |
| | | import static org.opends.server.TestCaseUtils.*; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | import static org.opends.server.util.CollectionUtils.*; |
| | | import static org.opends.server.util.StaticUtils.*; |
| | | import static org.testng.Assert.*; |
| | | |
| | | import java.net.InetSocketAddress; |
| | | import java.net.Socket; |
| | | import java.net.SocketTimeoutException; |
| | |
| | | import org.opends.server.replication.protocol.WindowProbeMsg; |
| | | import org.opends.server.replication.service.ReplicationBroker; |
| | | import org.opends.server.types.Attributes; |
| | | import org.opends.server.types.DirectoryConfig; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.Entry; |
| | | import org.opends.server.types.HostPort; |
| | |
| | | import org.testng.annotations.BeforeClass; |
| | | import org.testng.annotations.Test; |
| | | |
| | | import static org.forgerock.opendj.ldap.ModificationType.*; |
| | | import static org.opends.server.TestCaseUtils.*; |
| | | import static org.opends.server.replication.protocol.OperationContext.*; |
| | | import static org.opends.server.util.CollectionUtils.*; |
| | | import static org.opends.server.util.StaticUtils.*; |
| | | import static org.testng.Assert.*; |
| | | |
| | | /** Tests for the replicationServer code. */ |
| | | @SuppressWarnings("javadoc") |
| | | public class ReplicationServerTest extends ReplicationTestCase |
| | |
| | | ReplSessionSecurity replSessionSecurity = getReplSessionSecurity(); |
| | | Session session = replSessionSecurity.createClientSession(socket, timeoutMS); |
| | | |
| | | boolean sslEncryption = DirectoryConfig.getCryptoManager().isSslEncryption(); |
| | | boolean sslEncryption = getServerContext().getCryptoManager().isSslEncryption(); |
| | | |
| | | try |
| | | { |