Package fr.gouv.vitam.storage.offers.tape.inmemoryqueue

# Class QueueProcessor<T>

java.lang.Object
fr.gouv.vitam.storage.offers.tape.inmemoryqueue.QueueProcessor<T>

Direct Known Subclasses:
  `FileBucketTarCreator`, `WriteOrderCreator`

public abstract class QueueProcessor<T> extends Object

- ## Constructor Summary

  Constructors
  Modifier
  Constructor
  Description
  `protected`
  `QueueProcessor(String workerName)`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `void`
  `addFirst(T message)`
  `void`
  `addToQueue(T message)`
  `protected abstract void`
  `processMessage(T message)`
  `void`
  `startListener()`

  ### Methods inherited from class java.lang.Object

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

- ## Constructor Details

  - ### QueueProcessor

    protected QueueProcessor(String workerName)

- ## Method Details

  - ### startListener

    public void startListener()

  - ### addToQueue

    public void addToQueue(T message)

  - ### addFirst

    public void addFirst(T message)

  - ### processMessage

    protected abstract void processMessage(T message) throws QueueProcessingException, InterruptedException
    Throws:
      `QueueProcessingException`
      `InterruptedException`