fr.gouv.vitam.storage.offers.tape.cas

Class FileBucketTarCreator

java.lang.Object

fr.gouv.vitam.storage.offers.tape.inmemoryqueue.QueueProcessor<TarCreatorMessage>

fr.gouv.vitam.storage.offers.tape.cas.FileBucketTarCreator

public class FileBucketTarCreator
extends QueueProcessor<TarCreatorMessage>

Constructor Summary

Constructors

Constructor and Description
FileBucketTarCreator(BasicFileStorage basicFileStorage, ObjectReferentialRepository objectReferentialRepository, ArchiveReferentialRepository archiveReferentialRepository, WriteOrderCreator writeOrderCreator, String bucketId, String fileBucketId, int tarBufferingTimeout, TimeUnit tarBufferingTimeUnit, String inputTarStorageFolder, long maxTarEntrySize, long maxTarFileSize)

Method Summary

Modifier and Type	Method and Description
protected void	processMessage(TarCreatorMessage message)

Methods inherited from class fr.gouv.vitam.storage.offers.tape.inmemoryqueue.QueueProcessor

addFirst, addToQueue, startListener

Methods inherited from class java.lang.Object

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

Constructor Detail

FileBucketTarCreator

public FileBucketTarCreator(BasicFileStorage basicFileStorage,
                            ObjectReferentialRepository objectReferentialRepository,
                            ArchiveReferentialRepository archiveReferentialRepository,
                            WriteOrderCreator writeOrderCreator,
                            String bucketId,
                            String fileBucketId,
                            int tarBufferingTimeout,
                            TimeUnit tarBufferingTimeUnit,
                            String inputTarStorageFolder,
                            long maxTarEntrySize,
                            long maxTarFileSize)

Method Detail

processMessage

protected void processMessage(TarCreatorMessage message)
                       throws QueueProcessingException

Specified by:

processMessage in class QueueProcessor<TarCreatorMessage>

Throws:

QueueProcessingException