Class AbstractExecutorEventWorker

java.lang.Object
ru.bitel.bgbilling.kernel.event.AbstractExecutorEventWorker
All Implemented Interfaces:
javax.jms.MessageListener, ru.bitel.bgbilling.kernel.application.server.Lifecycle, EventListener<ru.bitel.bgbilling.kernel.event.common.Event>
Direct Known Subclasses:
ExecutorEventWorker

public abstract class AbstractExecutorEventWorker extends Object implements EventListener<ru.bitel.bgbilling.kernel.event.common.Event>, javax.jms.MessageListener, ru.bitel.bgbilling.kernel.application.server.Lifecycle
  • Field Details

    • consumer

      protected final ru.bitel.bgbilling.kernel.event.AbstractConsumer consumer
    • moduleId

      protected final int moduleId
  • Constructor Details

    • AbstractExecutorEventWorker

      public AbstractExecutorEventWorker(EventProcessor ep, Class<? extends ru.bitel.bgbilling.kernel.event.common.Event> clazz, int moduleId, int pluginId, String query) throws ru.bitel.bgbilling.common.BGException
      Throws:
      ru.bitel.bgbilling.common.BGException
    • AbstractExecutorEventWorker

      public AbstractExecutorEventWorker(EventProcessor ep, String destination, int moduleId, int pluginId, String query, Class<?>... clazz) throws ru.bitel.bgbilling.common.BGException
      Throws:
      ru.bitel.bgbilling.common.BGException
  • Method Details

    • start

      public void start() throws ru.bitel.bgbilling.common.BGException
      Specified by:
      start in interface ru.bitel.bgbilling.kernel.application.server.Lifecycle
      Throws:
      ru.bitel.bgbilling.common.BGException
    • stop

      public void stop() throws ru.bitel.bgbilling.common.BGException
      Specified by:
      stop in interface ru.bitel.bgbilling.kernel.application.server.Lifecycle
      Throws:
      ru.bitel.bgbilling.common.BGException
    • shutdown

      public void shutdown() throws ru.bitel.bgbilling.common.BGException
      Throws:
      ru.bitel.bgbilling.common.BGException
    • getLogger

      protected org.apache.logging.log4j.Logger getLogger()