| | |
| | | { |
| | | final LDAPReplicationDomain domain = new LDAPReplicationDomain( |
| | | configuration, updateToReplayQueue, dsrsShutdownSync); |
| | | if (domains.size() == 0) |
| | | if (domains.isEmpty()) |
| | | { |
| | | // Create the threads that will process incoming update messages |
| | | createReplayThreads(); |
| | |
| | | } |
| | | |
| | | // No replay threads running if no replication need |
| | | if (domains.size() == 0) { |
| | | if (domains.isEmpty()) { |
| | | stopReplayThreads(); |
| | | } |
| | | } |
| | |
| | | // Stop threads then restart new number of threads |
| | | stopReplayThreads(); |
| | | replayThreadNumber = numUpdateRepayThread; |
| | | if (domains.size() > 0) |
| | | if (!domains.isEmpty()) |
| | | { |
| | | createReplayThreads(); |
| | | } |