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

neil_a_wilson
29.12.2007 42b383614d9a4720f6f0c91fb770a389cfa41738
opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java
@@ -27,8 +27,6 @@
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;
@@ -347,10 +345,6 @@
          {
            if (session != null)
            {
              logError(ErrorLogCategory.SYNCHRONIZATION,
                  ErrorLogSeverity.NOTICE,
                  "Broker : connect closing session" , 1);
              session.close();
              session = null;
            }
@@ -504,7 +498,6 @@
      try
      {
        SynchronizationMessage msg = session.receive();
        if (msg instanceof WindowMessage)
        {
          WindowMessage windowMsg = (WindowMessage) msg;
@@ -551,11 +544,6 @@
    connected = false;
    try
    {
      if (debugEnabled())
      {
        debugInfo("ChangelogBroker Stop Closing session");
      }
      session.close();
    } catch (IOException e)
    {}
@@ -694,12 +682,4 @@
  {
    return numLostConnections;
  }
  private void log(String message)
  {
    int    msgID   = MSGID_UNKNOWN_TYPE;
    logError(ErrorLogCategory.SYNCHRONIZATION,
           ErrorLogSeverity.SEVERE_ERROR,
           message, msgID);
  }
}