Package 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

Description

FileBucketTarCreator(BasicFileStorage basicFileStorage, ObjectReferentialRepository objectReferentialRepository, ArchiveReferentialRepository archiveReferentialRepository, WriteOrderCreator writeOrderCreator, java.lang.String bucketId, java.lang.String fileBucketId, int tarBufferingTimeout, java.util.concurrent.TimeUnit tarBufferingTimeUnit, java.lang.String inputTarStorageFolder, long maxTarEntrySize, long maxTarFileSize)

Method Summary

Modifier and Type	Method	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,
                            java.lang.String bucketId,
                            java.lang.String fileBucketId,
                            int tarBufferingTimeout,
                            java.util.concurrent.TimeUnit tarBufferingTimeUnit,
                            java.lang.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