Minor fix to improve reliability of unit test ECLSimultaneousPsearches
| | |
| | | } |
| | | |
| | | /** |
| | | * Set a new change time heartbeat interval to this broker. |
| | | * @param changeTimeHeartbeatInterval The new interval (in ms). |
| | | */ |
| | | public void setChangeTimeHeartbeatInterval(int changeTimeHeartbeatInterval) |
| | | { |
| | | stopChangeTimeHeartBeatPublishing(); |
| | | this.changeTimeHeartbeatSendInterval = changeTimeHeartbeatInterval; |
| | | startChangeTimeHeartBeatPublishing(); |
| | | } |
| | | |
| | | /** |
| | | * Set the connectRequiresRecovery to the provided value. |
| | | * This flag is used to indicate if a recovery of Update is necessary |
| | | * after a reconnection to a RS. |
| | |
| | | DN.decode(TEST_ROOT_DN_STRING), 1201, |
| | | 100, replicationServerPort, |
| | | brokerSessionTimeout, true); |
| | | server01.setChangeTimeHeartbeatInterval(100); //ms |
| | | int ts = 1; |
| | | |
| | | // Create broker on o=test2 |
| | |
| | | DN.decode(TEST_ROOT_DN_STRING2), 1202, |
| | | 100, replicationServerPort, |
| | | brokerSessionTimeout, true, EMPTY_DN_GENID); |
| | | server02.setChangeTimeHeartbeatInterval(100); //ms |
| | | |
| | | // Produce update 1 |
| | | ChangeNumber cn1 = |