@ -5,8 +5,6 @@ import com.amazonaws.auth.BasicAWSCredentials;
import com.amazonaws.client.builder.AwsClientBuilder ;
import com.amazonaws.client.builder.AwsClientBuilder ;
import com.amazonaws.services.s3.AmazonS3 ;
import com.amazonaws.services.s3.AmazonS3 ;
import com.amazonaws.services.s3.AmazonS3ClientBuilder ;
import com.amazonaws.services.s3.AmazonS3ClientBuilder ;
import com.amazonaws.services.s3.model.CopyObjectRequest ;
import com.amazonaws.services.s3.model.DeleteObjectRequest ;
import com.amazonaws.services.s3.model.GetObjectRequest ;
import com.amazonaws.services.s3.model.GetObjectRequest ;
import com.amazonaws.services.s3.model.ListObjectsRequest ;
import com.amazonaws.services.s3.model.ListObjectsRequest ;
import com.amazonaws.services.s3.model.ObjectListing ;
import com.amazonaws.services.s3.model.ObjectListing ;
@ -299,17 +297,16 @@ public class S3ResourceRepository extends BaseResourceRepository {
@Override
@Override
public boolean rename ( String path , String newPath ) throws ResourceIOException {
public boolean rename ( String path , String newPath ) throws ResourceIOException {
try {
CopyObjectRequest copyObjRequest = new CopyObjectRequest ( bucket ,
if ( copy ( path , newPath ) & & delete ( path ) ) {
path , bucket , newPath ) ;
if ( LogKit . isDebugEnabled ( ) ) {
s3 . copyObject ( copyObjRequest ) ;
LogKit . debug ( "[S3] rename {} to {} success." , path , newPath ) ;
s3 . deleteObject ( new DeleteObjectRequest ( bucket , path ) ) ;
} catch ( Exception e ) {
LogKit . error ( e . getMessage ( ) , e ) ;
return false ;
}
}
return true ;
return true ;
}
}
LogKit . error ( "[S3] rename {} to {} failed." , path , newPath ) ;
return false ;
}
@Override
@Override
public void shutDown ( ) {
public void shutDown ( ) {