Class NotificationCompletionService

java.lang.Object
org.exoplatform.commons.api.notification.service.NotificationCompletionService
All Implemented Interfaces:
org.picocontainer.Startable

public class NotificationCompletionService extends Object implements org.picocontainer.Startable
  • Constructor Details

    • NotificationCompletionService

      public NotificationCompletionService(org.exoplatform.container.xml.InitParams params)
  • Method Details

    • addTask

      public void addTask(Callable callable)
      Runs the task, on the pool when the execution is asynchronous. Neither its result nor an exception it lets escape is kept: a task logs its own errors.
      Parameters:
      callable - the task to run
    • waitCompletionFinished

      public void waitCompletionFinished()
    • isAsync

      public boolean isAsync()
    • isPoolThread

      public boolean isPoolThread()
      Returns:
      true when the current thread is a thread of the pool, false on any other thread, the caller of a synchronous execution included
    • start

      public void start()
      Specified by:
      start in interface org.picocontainer.Startable
    • stop

      public void stop()
      Specified by:
      stop in interface org.picocontainer.Startable