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 and Description
protected	QueueProcessor(String workerName)

Method Summary

Modifier and Type	Method and 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 Detail

QueueProcessor

protected QueueProcessor(String workerName)

Method Detail

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