Class PoolEventPublisher<E extends ru.bitel.bgbilling.kernel.event.common.Event>

java.lang.Object
ru.bitel.bgbilling.kernel.event.PoolEventPublisher<E>
All Implemented Interfaces:
Runnable
Direct Known Subclasses:
PoolQueueEventPublisher, PoolTopicEventPublisher

public abstract class PoolEventPublisher<E extends ru.bitel.bgbilling.kernel.event.common.Event> extends Object implements Runnable
See Also:
  • Field Details

  • Method Details

    • setMessageHandler

      public void setMessageHandler(MessageHandler messageHandler)
    • publish

      public void publish(E e) throws ru.bitel.bgbilling.common.BGException
      Throws:
      ru.bitel.bgbilling.common.BGException
    • run

      public void run()
      Specified by:
      run in interface Runnable
    • publish

      protected abstract void publish(EventProcessor eventProcessor, Class<E> clazz, List<E> list) throws ru.bitel.bgbilling.common.BGException
      Throws:
      ru.bitel.bgbilling.common.BGException
    • close

      public void close()
    • finalize

      protected void finalize() throws Throwable
      Overrides:
      finalize in class Object
      Throws:
      Throwable
    • publishAfterCommit

      public void publishAfterCommit(ru.bitel.common.worker.CommitableHandler context, E e)
      Публикует событие при вызове commit у context
      Parameters:
      context -
      e -
    • publishAfterCommit

      public void publishAfterCommit(E e)
      Публикует событие при вызове commit текущего ThreadContext.
      Parameters:
      e -
    • getModuleId

      public int getModuleId()
    • getPluginId

      public int getPluginId()