fr.gouv.vitam.storage.engine.server.distribution.impl.bulk

Class MultiplexedStreamTransferThread

java.lang.Object

fr.gouv.vitam.storage.engine.server.distribution.impl.bulk.MultiplexedStreamTransferThread

All Implemented Interfaces:

Callable<StorageBulkPutResult>

public class MultiplexedStreamTransferThread
extends Object
implements Callable<StorageBulkPutResult>

Constructor Summary

Constructors

Constructor and Description
MultiplexedStreamTransferThread(int tenantId, DataCategory dataCategory, List<String> objectIds, InputStream inputStream, long size, Driver driver, StorageOffer storageOffer, DigestType digestType)

Method Summary

Modifier and Type	Method and Description
StorageBulkPutResult	call()

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiplexedStreamTransferThread

public MultiplexedStreamTransferThread(int tenantId,
                                       DataCategory dataCategory,
                                       List<String> objectIds,
                                       InputStream inputStream,
                                       long size,
                                       Driver driver,
                                       StorageOffer storageOffer,
                                       DigestType digestType)

Method Detail

call

public StorageBulkPutResult call()
                          throws Exception

Specified by:

call in interface Callable<StorageBulkPutResult>

Throws:

Exception