Package ru.bitel.bgbilling.kernel.event

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

java.lang.Object
ru.bitel.bgbilling.kernel.event.PoolEventPublisher<E>
Type Parameters:
E -
All Implemented Interfaces:
java.lang.Runnable
Direct Known Subclasses:
PoolQueueEventPublisher, PoolTopicEventPublisher
public abstract class PoolEventPublisher<E extends ru.bitel.bgbilling.kernel.event.common.Event>
extends java.lang.Object
implements java.lang.Runnable

  • Field Summary

    Fields
    Modifier and Type Field Description
    protected MessageHandler messageHandler  

  • Method Summary

    Modifier and Type Method Description
    void close()  
    protected void finalize()  
    int getModuleId()  
    int getPluginId()  
    void publish​(E e)  
    protected abstract void publish​(EventProcessor eventProcessor, java.lang.Class<E> clazz, java.util.List<E> list)  
    void publishAfterCommit​(E e)
    Публикует событие при вызове commit текущего ThreadContext.
    void publishAfterCommit​(ru.bitel.common.worker.CommitableHandler context, E e)
    Публикует событие при вызове commit у context
    void run()  
    void setMessageHandler​(MessageHandler messageHandler)  

    Methods inherited from class java.lang.Object

    clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • 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 java.lang.Runnable

    • publish

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

    • close

      public void close()

    • finalize

      protected void finalize() throws java.lang.Throwable
      Overrides:
      finalize in class java.lang.Object
      Throws:
      java.lang.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()