pgamba

29.53.2007 40cef7d36084fbe86d34cfa497628d8972c4c9e7

 opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java

@@ -27,6 +27,8 @@
package org.opends.server.synchronization.plugin;

import static org.opends.server.loggers.Error.logError;
import static org.opends.server.loggers.debug.DebugLogger.debugEnabled;
import static org.opends.server.loggers.debug.DebugLogger.debugInfo;
import static org.opends.server.messages.MessageHandler.getMessage;
import static org.opends.server.synchronization.common.LogMessages.*;
import static org.opends.server.util.StaticUtils.stackTraceToSingleLineString;
@@ -345,6 +347,10 @@
          {
            if (session != null)
            {
              logError(ErrorLogCategory.SYNCHRONIZATION,
                  ErrorLogSeverity.NOTICE,
                  "Broker : connect closing session" , 1);

              session.close();
              session = null;
            }
@@ -498,6 +504,7 @@
      try
      {
        SynchronizationMessage msg = session.receive();

        if (msg instanceof WindowMessage)
        {
          WindowMessage windowMsg = (WindowMessage) msg;
@@ -544,6 +551,11 @@
    connected = false;
    try
    {
      if (debugEnabled())
      {
        debugInfo("ChangelogBroker Stop Closing session");
      }

      session.close();
    } catch (IOException e)
    {}
@@ -682,4 +694,12 @@
  {
    return numLostConnections;
  }

  private void log(String message)
  {
    int    msgID   = MSGID_UNKNOWN_TYPE;
    logError(ErrorLogCategory.SYNCHRONIZATION,
           ErrorLogSeverity.SEVERE_ERROR,
           message, msgID);
  }
}