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