Package 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	Description
MultiplexedStreamTransferThread(int tenantId, String requestId, DataCategory dataCategory, List<String> objectIds, InputStream inputStream, long size, Driver driver, StorageOffer storageOffer, DigestType digestType)

Method Summary

Modifier and Type	Method	Description
StorageBulkPutResult	call()

Methods inherited from class java.lang.Object

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

Constructor Details

MultiplexedStreamTransferThread

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

Method Details

call

public StorageBulkPutResult call()
                          throws Exception

Specified by:

call in interface Callable<StorageBulkPutResult>

Throws:

Exception