| | |
| | | */ |
| | | final int serverId = 2; |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000, true); |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000); |
| | | |
| | | try |
| | | { |
| | |
| | | */ |
| | | int serverId = 2; |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000, true); |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000); |
| | | |
| | | try |
| | | { |
| | |
| | | * This must use a different serverId to that of the directory server. |
| | | */ |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, 2, 100, replServerPort, 1000, true); |
| | | openReplicationSession(baseDN, 2, 100, replServerPort, 1000); |
| | | |
| | | try |
| | | { |
| | |
| | | */ |
| | | final int serverId = 2; |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000, true); |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000); |
| | | try |
| | | { |
| | | CSNGenerator gen = new CSNGenerator(serverId, 0); |
| | |
| | | |
| | | final int serverId = 27; |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 2000, true); |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 2000); |
| | | try { |
| | | CSNGenerator gen = new CSNGenerator(serverId, 0); |
| | | |
| | |
| | | |
| | | int serverId = 11; |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000, true); |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000); |
| | | try |
| | | { |
| | | CSNGenerator gen = new CSNGenerator(serverId, 0); |
| | |
| | | */ |
| | | final int serverId = 88; |
| | | ReplicationBroker broker = |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000, true); |
| | | openReplicationSession(baseDN, serverId, 100, replServerPort, 1000); |
| | | consumeAllMessages(broker); // clean leftover messages from lostHeartbeatFailover() |
| | | try |
| | | { |