| | |
| | | @Override |
| | | public ChangeNumberIndexDB getChangeNumberIndexDB() |
| | | { |
| | | return getChangeNumberIndexDB(true); |
| | | } |
| | | |
| | | /** |
| | | * Returns the {@link ChangeNumberIndexDB} object. |
| | | * |
| | | * @param startTrimmingThread |
| | | * whether the trimming thread should be started |
| | | * @return the {@link ChangeNumberIndexDB} object |
| | | */ |
| | | ChangeNumberIndexDB getChangeNumberIndexDB(boolean startTrimmingThread) |
| | | { |
| | | synchronized (cnIndexDBLock) |
| | | { |
| | | if (cnIndexDB == null) |
| | |
| | | try |
| | | { |
| | | cnIndexDB = new JEChangeNumberIndexDB(replicationServer, this.dbEnv); |
| | | cnIndexDB.startTrimmingThread(); |
| | | if (startTrimmingThread) |
| | | { |
| | | cnIndexDB.startTrimmingThread(); |
| | | } |
| | | } |
| | | catch (Exception e) |
| | | { |