Interface BackendQueueProcessorFactory

All Known Subinterfaces:
UpdatableBackendQueueProcessorFactory
All Known Implementing Classes:
BlackHoleBackendQueueProcessorFactory, JGroupsBackendQueueProcessorFactory, JMSBackendQueueProcessorFactory, LuceneBackendQueueProcessorFactory, MasterJGroupsBackendQueueProcessorFactory, SlaveJGroupsBackendQueueProcessorFactory

public interface BackendQueueProcessorFactory
Interface for different types of queue processor factories. Implementations need a no-arg constructor. The factory typically prepares or pools the resources needed by the queue processor.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Used to shutdown and eventually release resources.
    Return a runnable implementation responsible for processing the queue to a given backend.
    void
    Used at startup, called once as first method.
  • Method Details

    • initialize

      void initialize(Properties props, WorkerBuildContext context)
      Used at startup, called once as first method.
      Parameters:
      props - all configuration properties
      context - context giving access to required meta data
    • getProcessor

      Runnable getProcessor(List<LuceneWork> queue)
      Return a runnable implementation responsible for processing the queue to a given backend.
      Parameters:
      queue - The work queue to process.
      Returns:
      Runnable which processes queue when started.
    • close

      void close()
      Used to shutdown and eventually release resources. No other method should be used after this one.