org.waarp.openr66.context.task

Class S3GetAndDeleteTask

java.lang.Object

org.waarp.openr66.context.task.AbstractTask

org.waarp.openr66.context.task.S3AbstractTask

org.waarp.openr66.context.task.S3GetTask

org.waarp.openr66.context.task.S3GetAndDeleteTask

All Implemented Interfaces:

Runnable

public class S3GetAndDeleteTask
extends S3GetTask

S3 GET and DELETE Task

The Rule shall be using SENDMD5THROUGHMODE or SENDTHROUGHMODE mode (respectively 7 or 5) or RECVMD5THROUGHMODE or RECVTHROUGHMODE mode (respectively 8 or 6) as pre-tasks since the file does not exist at startup.

Result of arguments will be as a S3 GET command.
Format is the following:
"-URL url of S3 service
-accessKey access Key for S3 service
-secretKey secret Key for S3 service
-bucketName bucket Name where to retrieve the object
-sourceName source Name from the bucket to select the final Object
-file final File path (absolute or relative from IN path)
[-getTags [* or list of tag names comma separated without space]]"


The order of actions will be:
1) connection to S3 service using access Key and Secret Key
2) Retrieve from the bucket the source Object and store it in the file specified
3) if getTags is true, the informations are added to transferInfo and fileInfo
4) the current File is set to this new GET file
5) the sender send an update on file information (name and size)
6) the remote S3 Object is deleted

Field Summary

Fields inherited from class org.waarp.openr66.context.task.AbstractTask

ARCHPATH, BLANK, BLOCKSIZE, COMPRESS, DATE, ERRORCODE, ERRORMSG, ERRORSTRCODE, FILESIZE, FULLTRANSFERID, HOMEPATH, HOUR, INPATH, LOCALEXEC, LOCALHOST, LOCALHOSTADDR, NOWAIT, ORIGINALFILENAME, ORIGINALFULLPATH, OUTPATH, RANKTRANSFER, REMOTEHOST, REMOTEHOSTADDR, REQUESTEDHOST, REQUESTERHOST, RULE, TRANSFERID, TRUEFILENAME, TRUEFULLPATH, WORKPATH

Constructor Summary

Constructors

Constructor and Description
S3GetAndDeleteTask(String argRule, int delay, String argTransfer, R66Session session) Constructor

Method Summary

Modifier and Type	Method and Description
S3TaskFactory.S3TaskType	getS3TaskType()
void	run() The order of actions will be: 1) connection to S3 service using access Key and Secret Key 2) Retrieve from the bucket the source Object and store it in the file specified 3) if getTags is true, the informations are added to transferInfo and fileInfo 4) the current File is set to this new GET file 5) the sender send an update on file information (name and size) 6) the remote S3 Object is deleted

Methods inherited from class org.waarp.openr66.context.task.S3AbstractTask

finalizeInError, getParams

Methods inherited from class org.waarp.openr66.context.task.AbstractTask

applyTransferSubstitutions, getFutureCompletion, getReplacedValue, getSubstitutionMap, getType, isCompressionRequested, isSuccess

Methods inherited from class java.lang.Object

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

Constructor Detail

S3GetAndDeleteTask

public S3GetAndDeleteTask(String argRule,
                          int delay,
                          String argTransfer,
                          R66Session session)

Constructor

Parameters:

argRule -

delay -

argTransfer -

session -

Method Detail

run

public void run()

The order of actions will be:
1) connection to S3 service using access Key and Secret Key
2) Retrieve from the bucket the source Object and store it in the file specified
3) if getTags is true, the informations are added to transferInfo and fileInfo
4) the current File is set to this new GET file
5) the sender send an update on file information (name and size)
6) the remote S3 Object is deleted

Specified by:

run in interface Runnable

Overrides:

run in class S3GetTask

getS3TaskType

public final S3TaskFactory.S3TaskType getS3TaskType()

Overrides:

getS3TaskType in class S3GetTask