Interface QueueingProcessor

All Known Implementing Classes:
BatchedQueueingProcessor

public interface QueueingProcessor
Pile work operations No thread safety has to be implemented, the queue being scoped already The implementation must be "stateless" wrt the queue through (ie not store the queue state) FIXME this Interface does not make much sense, since the impl will not be changed
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    add(Work work, WorkQueue workQueue)
    Add a work TODO move that somewhere else, it does not really fit here
    void
    Rollback works
    void
    clean resources This method should log errors rather than raise an exception
    void
    Execute works
    void
    prepare resources for a later performWorks call
  • Method Details

    • add

      void add(Work work, WorkQueue workQueue)
      Add a work TODO move that somewhere else, it does not really fit here
    • prepareWorks

      void prepareWorks(WorkQueue workQueue)
      prepare resources for a later performWorks call
    • performWorks

      void performWorks(WorkQueue workQueue)
      Execute works
    • cancelWorks

      void cancelWorks(WorkQueue workQueue)
      Rollback works
    • close

      void close()
      clean resources This method should log errors rather than raise an exception