public class ThreadedS3Service extends ThreadedStorageService
ThreadedStorageService.AbstractRunnable, ThreadedStorageService.ThreadGroupManager
isShutdown, serviceEventListeners, sleepTime, storageService
Constructor and Description |
---|
ThreadedS3Service(S3Service service,
StorageServiceEventListener listener) |
Modifier and Type | Method and Description |
---|---|
protected void |
fireServiceEvent(ServiceEvent event)
Sends a service event to each of the listeners registered with this service.
|
boolean |
multipartCompleteUploads(java.util.List<MultipartUpload> multipartUploads)
Completes multiple multipart uploads and sends
MultipartCompletesEvent notification events. |
boolean |
multipartStartUploads(java.lang.String bucketName,
java.util.List<StorageObject> objects)
Starts multiple multipart uploads and sends
MultipartStartsEvent notification events. |
boolean |
multipartUploadParts(java.util.List<MultipartUploadAndParts> uploadAndPartsList)
Uploads multiple objects that will constitute a single final object,
and sends
MultipartUploadsEvent notification events. |
addServiceEventListener, copyObjects, createBuckets, deleteObjects, deleteObjects, downloadObjects, downloadObjects, getObjectACLs, getObjects, getObjects, getObjects, getObjectsHeads, getObjectsHeads, getObjectsHeads, getProviderCredentials, getStorageService, isAuthenticatedConnection, isShutdown, listObjects, putACLs, putObjects, removeServiceEventListener, shutdown
public ThreadedS3Service(S3Service service, StorageServiceEventListener listener) throws ServiceException
ServiceException
protected void fireServiceEvent(ServiceEvent event)
ThreadedStorageService
fireServiceEvent
in class ThreadedStorageService
event
- the event to send to this service's registered event listeners.public boolean multipartStartUploads(java.lang.String bucketName, java.util.List<StorageObject> objects)
MultipartStartsEvent
notification events.
The maximum number of threads is controlled by the JetS3t configuration property threaded-service.max-admin-thread-count.
bucketName
- the target bucket.objects
- a list of objects representing the overall multipart object.public boolean multipartCompleteUploads(java.util.List<MultipartUpload> multipartUploads)
MultipartCompletesEvent
notification events.
The maximum number of threads is controlled by the JetS3t configuration property threaded-service.max-admin-thread-count.
multipartUploads
- a list of objects representing the multipart-uploads that will be completed.public boolean multipartUploadParts(java.util.List<MultipartUploadAndParts> uploadAndPartsList)
MultipartUploadsEvent
notification events.
The maximum number of threads is controlled by the JetS3t configuration property threaded-service.max-admin-thread-count.
uploadAndPartsList
- list of wrapper objects containing a previously-started MultipartUpload and a
list of objects representing the parts that will make up the final object.