public class BatchManagerComponent extends DefaultComponent implements BatchManager
BatchManager
serviceConstructor and Description |
---|
BatchManagerComponent() |
Modifier and Type | Method and Description |
---|---|
void |
addStream(String batchId,
String idx,
InputStream is,
String name,
String mime)
Add an inputStream in a batch Will create a new
Batch if needed
Streams are persisted as temporary files |
void |
clean(String batchId)
Cleanup the temporary storage associated to the batch
|
Object |
execute(String batchId,
String chainOrOperationId,
CoreSession session,
Map<String,Object> contextParams,
Map<String,Object> operationParams)
Executes the chain or operation on the
Blobs from the given
batchId . |
Object |
execute(String batchId,
String fileIdx,
String chainOrOperationId,
CoreSession session,
Map<String,Object> contextParams,
Map<String,Object> operationParams)
Executes the chain or operation on the
Blob from the given
batchId and fileIdx . |
Object |
executeAndClean(String batchId,
String chainOrOperationId,
CoreSession session,
Map<String,Object> contextParams,
Map<String,Object> operationParams)
Executes the chain or operation on the
Blobs from the given
batchId . |
Blob |
getBlob(String batchId,
String fileId) |
Blob |
getBlob(String batchId,
String fileId,
int timeoutS) |
List<Blob> |
getBlobs(String batchId)
Get Blobs associated to a given batch.
|
List<Blob> |
getBlobs(String batchId,
int timeoutS)
Get Blobs associated to a given batch.
|
boolean |
hasBatch(String batchId)
Returns true if there is a batch for the given
batchId , false
otherwise. |
String |
initBatch(String batchId,
String contextName)
Initialize a batch with a given batchId and Context Name If batchId is
not provided, it will be automatically generated
|
activate, applicationStarted, deactivate, getAdapter, getApplicationStartedOrder, getLastModified, registerContribution, registerExtension, setLastModified, unregisterContribution, unregisterExtension
public String initBatch(String batchId, String contextName)
BatchManager
initBatch
in interface BatchManager
public void addStream(String batchId, String idx, InputStream is, String name, String mime) throws IOException
BatchManager
Batch
if needed
Streams are persisted as temporary filesaddStream
in interface BatchManager
IOException
public boolean hasBatch(String batchId)
BatchManager
batchId
, false
otherwise.hasBatch
in interface BatchManager
public List<Blob> getBlobs(String batchId)
BatchManager
getBlobs
in interface BatchManager
public List<Blob> getBlobs(String batchId, int timeoutS)
BatchManager
getBlobs
in interface BatchManager
public Blob getBlob(String batchId, String fileId)
getBlob
in interface BatchManager
public Blob getBlob(String batchId, String fileId, int timeoutS)
getBlob
in interface BatchManager
public void clean(String batchId)
BatchManager
clean
in interface BatchManager
public Object execute(String batchId, String chainOrOperationId, CoreSession session, Map<String,Object> contextParams, Map<String,Object> operationParams) throws ClientException
BatchManager
Blobs
from the given
batchId
.
This method does not clean the temporary storage associated to the
batchId
.
execute
in interface BatchManager
ClientException
public Object execute(String batchId, String fileIdx, String chainOrOperationId, CoreSession session, Map<String,Object> contextParams, Map<String,Object> operationParams) throws ClientException
BatchManager
Blob
from the given
batchId
and fileIdx
.
This method does not clean the temporary storage associated to the
batchId
.
execute
in interface BatchManager
ClientException
public Object executeAndClean(String batchId, String chainOrOperationId, CoreSession session, Map<String,Object> contextParams, Map<String,Object> operationParams) throws ClientException
BatchManager
Blobs
from the given
batchId
.
This method clean the temporary storage associated to the batchId
after the execution.
executeAndClean
in interface BatchManager
ClientException
Copyright © 2013 Nuxeo SA. All Rights Reserved.