| | |
| | | |
| | | ReplicationBroker broker = new ReplicationBroker(null, |
| | | state, baseDn.toNormalizedString(), serverId, window_size, |
| | | generationId, 100000, getReplSessionSecurity(), (byte)1); |
| | | generationId, 100000, getReplSessionSecurity(), (byte)1, 500); |
| | | ArrayList<String> servers = new ArrayList<String>(1); |
| | | servers.add("localhost:" + port); |
| | | broker.start(servers); |
| | |
| | | { |
| | | ReplicationBroker broker = new ReplicationBroker(null, |
| | | state, baseDn.toNormalizedString(), serverId, window_size, generationId, |
| | | 100000, getReplSessionSecurity(), (byte)1); |
| | | 100000, getReplSessionSecurity(), (byte)1, 500); |
| | | ArrayList<String> servers = new ArrayList<String>(1); |
| | | servers.add("localhost:" + port); |
| | | broker.start(servers); |
| | |
| | | |
| | | ReplicationBroker broker = new ReplicationBroker(null, |
| | | state, baseDn.toNormalizedString(), serverId, window_size, |
| | | generationId, 0, getReplSessionSecurity(), (byte)1); |
| | | generationId, 0, getReplSessionSecurity(), (byte)1, 500); |
| | | ArrayList<String> servers = new ArrayList<String>(1); |
| | | servers.add("localhost:" + port); |
| | | broker.start(servers); |