Interface Worker

All Known Implementing Classes:
TransactionalWorker

public interface Worker
Perform work for a given context (eg a transaction). This implementation has to be threaded-safe.
  • Method Details

    • performWork

      void performWork(Work<?> work, TransactionContext transactionContext)
      Declare a work to be done within a given transaction context
      Parameters:
      work - the work to be executed
      transactionContext - transactional context information
    • initialize

      void initialize(Properties props, WorkerBuildContext context)
    • close

      void close()
      clean resources This method can return exceptions
    • flushWorks

      void flushWorks(TransactionContext transactionContext)
      Flush any work queue.
      Parameters:
      transactionContext - the current transaction (context).