| | |
| | | @SuppressWarnings("javadoc") |
| | | public class ReplicationServerTest extends ReplicationTestCase |
| | | { |
| | | /** The tracer object for the debug logger */ |
| | | /** The tracer object for the debug logger. */ |
| | | private static final LocalizedLogger logger = LocalizedLogger.getLoggerForThisClass(); |
| | | private DN TEST_ROOT_DN; |
| | | private DN EXAMPLE_DN; |
| | | /** The replicationServer that will be used in this test. */ |
| | | private ReplicationServer replicationServer; |
| | | |
| | | /** |
| | | * The port of the replicationServer. |
| | | */ |
| | | /** The port of the replicationServer. */ |
| | | private int replicationServerPort; |
| | | |
| | | private CSN firstCSNServer1; |
| | |
| | | |
| | | /** |
| | | * Test that a client that has already seen the first change now see the |
| | | * second change |
| | | * second change. |
| | | */ |
| | | private void newClientWithFirstChanges() throws Exception |
| | | { |
| | |
| | | |
| | | /** |
| | | * Test that a client that has already seen the first change from server 1 |
| | | * now see the first change from server 2 |
| | | * now see the first change from server 2. |
| | | */ |
| | | private void newClientWithChangefromServer1() throws Exception |
| | | { |
| | |
| | | |
| | | /** |
| | | * Test that a client that has already seen the first chaneg from server 2 |
| | | * now see the first change from server 1 |
| | | * now see the first change from server 1. |
| | | */ |
| | | private void newClientWithChangefromServer2() throws Exception |
| | | { |
| | |
| | | * <li>Create and connect client 2 to replication server 2</li> |
| | | * <li>Make client1 publish changes</li> |
| | | * <li>Check that client 2 receives the changes published by client 1</li> |
| | | * </ol> |
| | | * </ol>. |
| | | */ |
| | | @Test(enabled = true) |
| | | public void changelogChaining0() throws Exception |
| | |
| | | * <li>Create replication server 2 connected with replication server 1</li> |
| | | * <li>Create and connect client 2 to replication server 2</li> |
| | | * <li>Check that client 2 receives the changes published by client 1</li> |
| | | * <ol> |
| | | * <ol>. |
| | | */ |
| | | @Test(enabled = true) |
| | | public void changelogChaining1() throws Exception |
| | |
| | | private String errDetails; |
| | | |
| | | /** |
| | | * Creates a new Stress Test Reader |
| | | * Creates a new Stress Test Reader. |
| | | */ |
| | | public BrokerReader(ReplicationBroker broker, int numMsgExpected) |
| | | { |
| | |
| | | this.numMsgExpected = numMsgExpected; |
| | | } |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void run() |
| | | { |
| | |
| | | this.gen = gen; |
| | | } |
| | | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public void run() |
| | | { |
| | |
| | | * - Change the config of replication server 1 to no more be connected |
| | | * to server 2 |
| | | * - Make client 1 publish a change |
| | | * - Check that client 2 does not receive the change |
| | | * - Check that client 2 does not receive the change. |
| | | */ |
| | | @Test(enabled = true, groups = "opendj-256") |
| | | public void replicationServerConnected() throws Exception |