Fix OPENDJ-1354 - replication threads BLOCKED in pendingChanges queue

Matthew Swift

25.02.2014 21af6610b07617ecbf1b826310a2f244deb4d348

 opendj3-server-dev/src/server/org/opends/server/replication/protocol/MonitorMsg.java

@@ -50,12 +50,24 @@
 * When RS2 receives a MonitorRequestMessage from RS1, RS2 responds with a
 * MonitorMsg.
 */
public class MonitorMsg extends RoutableMsg
public class MonitorMsg extends ReplicationMsg
{
  /**
   * Data structure to manage the state and the approximation
   * of the data of the first missing change for each LDAP server
   * connected to a Replication Server.
   * The destination server or servers of this message.
   */
  private final int destination;

  /**
   * The serverID of the server that sends this message.
   */
  private final int senderID;



  /**
   * Data structure to manage the state and the approximation of the data of the
   * first missing change for each LDAP server connected to a Replication
   * Server.
   */
  static class ServerData
  {
@@ -89,24 +101,7 @@
   */
  public MonitorMsg(int sender, int destination)
  {
    super(sender, destination);
  }

  /**
   * Sets the sender ID.
   * @param senderID The sender ID.
   */
  public void setSenderID(int senderID)
  {
    this.senderID = senderID;
  }

  /**
   * Sets the destination.
   * @param destination The destination.
   */
  public void setDestination(int destination)
  {
    this.senderID = sender;
    this.destination = destination;
  }

@@ -459,6 +454,32 @@
    return data.rsStates.keySet().iterator();
  }



  /**
   * Get the destination.
   *
   * @return the destination
   */
  public int getDestination()
  {
    return destination;
  }



  /**
   * Get the server ID of the server that sent this message.
   *
   * @return the server id
   */
  public int getSenderID()
  {
    return senderID;
  }



  /**
   * {@inheritDoc}
   */