| | |
| | | private volatile boolean shutdown = false; |
| | | private int rcvWindow; |
| | | private int queueSize; |
| | | private final ChangelogDB changelogDB = new JEChangelogDB(this); |
| | | private final ChangelogDB changelogDB; |
| | | |
| | | /** |
| | | * The delay (in sec) after which the changes must be deleted from the |
| | |
| | | purgeDelay = configuration.getReplicationPurgeDelay(); |
| | | rcvWindow = configuration.getWindowSize(); |
| | | |
| | | this.changelogDB.setReplicationDBDirectory(configuration |
| | | .getReplicationDBDirectory()); |
| | | this.changelogDB = |
| | | new JEChangelogDB(this, configuration.getReplicationDBDirectory()); |
| | | |
| | | groupId = (byte)configuration.getGroupId(); |
| | | weight = configuration.getWeight(); |
| | |
| | | } |
| | | |
| | | final String newDir = configuration.getReplicationDBDirectory(); |
| | | if (newDir != null && !this.changelogDB.getDBDirName().equals(newDir)) |
| | | if (newDir != null && !this.changelogDB.getDBDirectoryName().equals(newDir)) |
| | | { |
| | | return new ConfigChangeResult(ResultCode.SUCCESS, true); |
| | | } |
| | |
| | | */ |
| | | public String getDbDirName() |
| | | { |
| | | return this.changelogDB.getDBDirName(); |
| | | return this.changelogDB.getDBDirectoryName(); |
| | | } |
| | | |
| | | /** |