org.jets3t.service.multi

Class ThreadedStorageService.DownloadObjectRunnable

java.lang.Object

org.jets3t.service.multi.ThreadedStorageService.AbstractRunnable

org.jets3t.service.multi.ThreadedStorageService.DownloadObjectRunnable

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

ThreadedStorageService

private class ThreadedStorageService.DownloadObjectRunnable
extends ThreadedStorageService.AbstractRunnable

Thread for downloading an object. The download 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 java.lang.String	bucketName
private DownloadPackage	downloadPackage
private ErrorPermitter	errorPermitter
private InterruptableInputStream	interruptableInputStream
private java.lang.String	objectKey
private BytesProgressWatcher	progressMonitor
private boolean	restoreLastModifiedDate
private java.lang.Object	result

Constructor Summary

Constructors

Constructor and Description
DownloadObjectRunnable(java.lang.String bucketName, java.lang.String objectKey, DownloadPackage downloadPackage, BytesProgressWatcher progressMonitor, boolean restoreLastModifiedDate, ErrorPermitter errorPermitter)

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

objectKey

private java.lang.String objectKey

bucketName

private java.lang.String bucketName

downloadPackage

private DownloadPackage downloadPackage

interruptableInputStream

private InterruptableInputStream interruptableInputStream

progressMonitor

private BytesProgressWatcher progressMonitor

restoreLastModifiedDate

private boolean restoreLastModifiedDate

errorPermitter

private ErrorPermitter errorPermitter

result

private java.lang.Object result

Constructor Detail

DownloadObjectRunnable

public DownloadObjectRunnable(java.lang.String bucketName,
                              java.lang.String objectKey,
                              DownloadPackage downloadPackage,
                              BytesProgressWatcher progressMonitor,
                              boolean restoreLastModifiedDate,
                              ErrorPermitter errorPermitter)

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