Package ru.bitel.bgbilling.modules.cerbercrypt.server.task

Class SubscribeSynchronizer

java.lang.Object
ru.bitel.bgbilling.kernel.task.server.bean.RunTask
ru.bitel.bgbilling.modules.cerbercrypt.server.task.SubscribeSynchronizer
All Implemented Interfaces:
java.io.Serializable, java.lang.Runnable
public class SubscribeSynchronizer
extends RunTask
Задача синхронизации, запускается после каждого изменения карты итд. Выполняет периодическую задачу с указанием перечня конкретных карт.
See Also:
Serialized Form

  • Field Summary

    Fields inherited from class ru.bitel.bgbilling.kernel.task.server.bean.RunTask

    log, setup

  • Constructor Summary

    Constructors
    Constructor Description
    SubscribeSynchronizer​(int mid, java.util.Collection<UserCard> usercards)  
    SubscribeSynchronizer​(int mid, UserCard usercard)  

  • Method Summary

    Modifier and Type Method Description
    void executeTask()  
    java.lang.String getDescription()  
    java.lang.String getUniqueKeyParallel()
    Ключ, который показывает уникальность этой задачи для запуска одновременно/параллельно.
    java.lang.String getUniqueKeyQueue()
    Ключ, который показывает уникальность этой задачи для очереди.

    Methods inherited from class ru.bitel.bgbilling.kernel.task.server.bean.RunTask

    getQueueId, init, removeMyselfFromTable, run, setQueueId

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • SubscribeSynchronizer

      public SubscribeSynchronizer​(int mid, UserCard usercard)

    • SubscribeSynchronizer

      public SubscribeSynchronizer​(int mid, java.util.Collection<UserCard> usercards)

  • Method Details

    • getDescription

      public java.lang.String getDescription()
      Specified by:
      getDescription in class RunTask

    • executeTask

      public void executeTask()
      Specified by:
      executeTask in class RunTask

    • getUniqueKeyQueue

      public java.lang.String getUniqueKeyQueue()
      Description copied from class: RunTask
      Ключ, который показывает уникальность этой задачи для очереди. Задачи с одинаковым ключом, не равным null: при выборке шедулером (в TaskRunProcessor) считаются дублирующимися и схлопываются в одну. Если надо, чтобы задачи не копились кучей одинаковых в очереди - надо перегрузить этот метод. Пример: синхронизация одной и той же сущности в cerbercrypt. Хорошей практикой является ключ типа "модуль-мид-имятаска-какиетохарактеристикизадачи".
      Overrides:
      getUniqueKeyQueue in class RunTask

    • getUniqueKeyParallel

      public java.lang.String getUniqueKeyParallel()
      Description copied from class: RunTask
      Ключ, который показывает уникальность этой задачи для запуска одновременно/параллельно. Задачи с одинаковым ключом, не равным null: если сейчас уже запущена задача с таким же ключом, то эта задача остаётся в очереди, не запускается параллельно. Если надо, чтобы задачи не выполнялись параллельно, а ждали завершения предыдущей такой же - надо перегрузить этот метод. Пример: синхронизация в одну и ту же CAS разных сущностей cerbercrypt (чаще всего на всякий случай). Хорошей практикой является ключ типа "модуль-мид-имятаска".
      Overrides:
      getUniqueKeyParallel in class RunTask