org.jets3t.service.multi.s3

Class ThreadedS3Service.MultipartUploadObjectRunnable

java.lang.Object

org.jets3t.service.multi.ThreadedStorageService.AbstractRunnable

org.jets3t.service.multi.s3.ThreadedS3Service.MultipartUploadObjectRunnable

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

ThreadedS3Service

private class ThreadedS3Service.MultipartUploadObjectRunnable
extends ThreadedStorageService.AbstractRunnable

Thread for creating/uploading an object that is part of a single multipart object. The upload of any object data is monitored with a ProgressMonitoredInputStream and can be can cancelled as the input stream is wrapped in an InterruptableInputStream.

Field Summary

Fields

Modifier and Type	Field and Description
private InterruptableInputStream	interruptableInputStream
private MultipartUpload	multipartUpload
private S3Object	object
private java.lang.Integer	partNumber
private BytesProgressWatcher	progressMonitor
private java.lang.Object	result

Constructor Summary

Constructors

Constructor and Description
MultipartUploadObjectRunnable(MultipartUpload multipartUpload, java.lang.Integer partNumber, S3Object object, BytesProgressWatcher progressMonitor)

Method Summary

Modifier and Type	Method and Description
void	forceInterruptCalled()
java.lang.Object	getResult()
void	run()

Methods inherited from class org.jets3t.service.multi.ThreadedStorageService.AbstractRunnable

forceInterrupt

Methods inherited from class java.lang.Object

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

Field Detail

multipartUpload

private MultipartUpload multipartUpload

partNumber

private java.lang.Integer partNumber

object

private S3Object object

interruptableInputStream

private InterruptableInputStream interruptableInputStream

progressMonitor

private BytesProgressWatcher progressMonitor

result

private java.lang.Object result

Constructor Detail

MultipartUploadObjectRunnable

public MultipartUploadObjectRunnable(MultipartUpload multipartUpload,
                                     java.lang.Integer partNumber,
                                     S3Object object,
                                     BytesProgressWatcher progressMonitor)

Method Detail

run

public void run()

getResult

public java.lang.Object getResult()

Specified by:

getResult in class ThreadedStorageService.AbstractRunnable

forceInterruptCalled

public void forceInterruptCalled()

Specified by:

forceInterruptCalled in class ThreadedStorageService.AbstractRunnable