| | |
| | | // ID of the backend |
| | | private static final String backendId = "replicationChanges"; |
| | | |
| | | // At startup, the listen thread wait on this flag for the connet |
| | | // At startup, the listen thread wait on this flag for the connect |
| | | // thread to look for other servers in the topology. |
| | | private boolean connectedInTopology = false; |
| | | private final Object connectedInTopologyLock = new Object(); |
| | |
| | | public DbHandler newDbHandler(short id, DN baseDn) |
| | | throws DatabaseException |
| | | { |
| | | return new DbHandler(id, baseDn, this, dbEnv); |
| | | return new DbHandler(id, baseDn, this, dbEnv, queueSize); |
| | | } |
| | | |
| | | /** |
| | |
| | | } |
| | | |
| | | /** |
| | | * Get the queueSize for this replication server. |
| | | * |
| | | * @return The maximum size of the queues for this Replication Server |
| | | * |
| | | */ |
| | | public int getQueueSize() |
| | | { |
| | | return queueSize; |
| | | } |
| | | |
| | | /** |
| | | * Creates the backend associated to this replication server. |
| | | * @throws ConfigException |
| | | */ |