fr.gouv.vitam.storage.offers.tape.worker

Class TapeDriveWorkerManager

java.lang.Object

fr.gouv.vitam.storage.offers.tape.worker.TapeDriveWorkerManager

All Implemented Interfaces:

TapeDriveOrderConsumer, TapeDriveOrderProducer

public class TapeDriveWorkerManager
extends Object
implements TapeDriveOrderConsumer, TapeDriveOrderProducer

Constructor Summary

Constructors

Constructor and Description
TapeDriveWorkerManager(QueueRepository readWriteQueue, ArchiveReferentialRepository archiveReferentialRepository, ReadRequestReferentialRepository readRequestReferentialRepository, TapeLibraryPool tapeLibraryPool, Map<Integer,TapeCatalog> driveTape, String inputTarPath, boolean forceOverrideNonEmptyCartridges, ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy)

Method Summary

Modifier and Type	Method and Description
Optional<? extends ReadWriteOrder>	consume(TapeDriveWorker driveWorker)
void	enqueue(QueueMessageEntity entity)
QueueRepository	getQueue()
Optional<? extends ReadWriteOrder>	produce(TapeDriveWorker driveWorker)
void	shutdown()
void	shutdown(long timeout, TimeUnit timeUnit)
void	startWorkers()

Methods inherited from class java.lang.Object

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

Constructor Detail

TapeDriveWorkerManager

public TapeDriveWorkerManager(QueueRepository readWriteQueue,
                              ArchiveReferentialRepository archiveReferentialRepository,
                              ReadRequestReferentialRepository readRequestReferentialRepository,
                              TapeLibraryPool tapeLibraryPool,
                              Map<Integer,TapeCatalog> driveTape,
                              String inputTarPath,
                              boolean forceOverrideNonEmptyCartridges,
                              ArchiveOutputRetentionPolicy archiveOutputRetentionPolicy)

Method Detail

startWorkers

public void startWorkers()

enqueue

public void enqueue(QueueMessageEntity entity)
             throws QueueException

Throws:

QueueException

shutdown

public void shutdown()

shutdown

public void shutdown(long timeout,
                     TimeUnit timeUnit)

getQueue

public QueueRepository getQueue()

Specified by:

getQueue in interface TapeDriveOrderConsumer

consume

public Optional<? extends ReadWriteOrder> consume(TapeDriveWorker driveWorker)
                                           throws QueueException

Specified by:

consume in interface TapeDriveOrderConsumer

Throws:

QueueException

produce

public Optional<? extends ReadWriteOrder> produce(TapeDriveWorker driveWorker)
                                           throws QueueException

Specified by:

produce in interface TapeDriveOrderProducer

Throws:

QueueException