Update the task backend to provide a mechanism for sending e-mail messages ...

neil_a_wilson

31.30.2007 a0c742dc589e56e8b1a7498de1d165e039f58aac

 opendj-sdk/opends/src/server/org/opends/server/loggers/ErrorLogger.java

@@ -34,7 +34,10 @@
import java.lang.reflect.Method;
import java.lang.reflect.InvocationTargetException;

import org.opends.server.api.DirectoryThread;
import org.opends.server.api.ErrorLogPublisher;
import org.opends.server.backends.task.Task;
import org.opends.server.loggers.debug.DebugTracer;
import org.opends.server.messages.MessageHandler;
import org.opends.server.types.*;
import org.opends.server.admin.std.server.ErrorLogPublisherCfg;
@@ -47,7 +50,6 @@
import org.opends.server.core.DirectoryServer;

import static org.opends.server.loggers.debug.DebugLogger.*;
import org.opends.server.loggers.debug.DebugTracer;
import static org.opends.server.messages.ConfigMessages.*;
import static org.opends.server.util.StaticUtils.*;
import static org.opends.server.messages.MessageHandler.getMessage;
@@ -441,6 +443,16 @@
    {
      publisher.logError(category, severity, message, errorID);
    }

    if (Thread.currentThread() instanceof DirectoryThread)
    {
      DirectoryThread thread = (DirectoryThread) Thread.currentThread();
      Task task = thread.getAssociatedTask();
      if (task != null)
      {
        task.addLogMessage(severity, errorID, message);
      }
    }
  }


@@ -467,6 +479,16 @@
    {
      publisher.logError(category, severity, message, errorID);
    }

    if (Thread.currentThread() instanceof DirectoryThread)
    {
      DirectoryThread thread = (DirectoryThread) Thread.currentThread();
      Task task = thread.getAssociatedTask();
      if (task != null)
      {
        task.addLogMessage(severity, errorID, message);
      }
    }
  }


@@ -490,6 +512,16 @@
    {
      publisher.logError(category, severity, message, errorID);
    }

    if (Thread.currentThread() instanceof DirectoryThread)
    {
      DirectoryThread thread = (DirectoryThread) Thread.currentThread();
      Task task = thread.getAssociatedTask();
      if (task != null)
      {
        task.addLogMessage(severity, errorID, message);
      }
    }
  }
}