mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

gbellato
18.40.2008 66f48672bc7953e77364a9a7ae41f1e70d83534f
opends/src/server/org/opends/server/replication/server/ReplicationServer.java
@@ -134,7 +134,7 @@
  // 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();
@@ -554,7 +554,7 @@
  public DbHandler newDbHandler(short id, DN baseDn)
  throws DatabaseException
  {
    return new DbHandler(id, baseDn, this, dbEnv);
    return new DbHandler(id, baseDn, this, dbEnv, queueSize);
  }
  /**
@@ -827,6 +827,17 @@
  }
  /**
   * 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
   */