The documentation and the configuration of a Replication Domain allow a max...

gbellato

07.19.2009 ae408b6c09759f61754f3e7b39d5e5d6595c1fc4

 opendj-sdk/opends/src/server/org/opends/server/replication/server/MessageHandler.java

@@ -86,7 +86,7 @@
  /**
   * The serverID of the hosting replication server.
   */
  protected short replicationServerId;
  protected int replicationServerId;
  /**
   * Specifies the related replication server domain based on serviceId(baseDn).
   */
@@ -141,7 +141,7 @@
  public MessageHandler(
      int queueSize,
      String replicationServerURL,
      short replicationServerId,
      int replicationServerId,
      ReplicationServer replicationServer)
  {
    super("Message Handler");
@@ -363,7 +363,7 @@
          SortedSet<ReplicationIterator> iteratorSortedSet =
            new TreeSet<ReplicationIterator>(comparator);
          /* fill the lateQueue */
          for (short serverId : replicationServerDomain.getServers())
          for (int serverId : replicationServerDomain.getServers())
          {
            ChangeNumber lastCsn = serverState.getMaxChangeNumber(serverId);
            ReplicationIterator iterator =
@@ -529,7 +529,7 @@
          try
          {
            // Build a list of candidates iterator (i.e. db i.e. server)
            for (short serverId : replicationServerDomain.getServers())
            for (int serverId : replicationServerDomain.getServers())
            {
              // get the last already sent CN from that server
              ChangeNumber lastCsn = serverState.getMaxChangeNumber(serverId);