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:

java.util.concurrent.Callable<StorageBulkPutResult>

public class MultiplexedStreamTransferThread
extends java.lang.Object
implements java.util.concurrent.Callable<StorageBulkPutResult>

Constructor Summary

Constructors

Constructor	Description
MultiplexedStreamTransferThread(int tenantId, java.lang.String requestId, DataCategory dataCategory, java.util.List<java.lang.String> objectIds, java.io.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 Detail

MultiplexedStreamTransferThread

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

Method Detail

call

public StorageBulkPutResult call()
                          throws java.lang.Exception

Specified by:

call in interface java.util.concurrent.Callable<StorageBulkPutResult>

Throws:

java.lang.Exception