org.gytheio.content.handler.s3

Class S3ContentReferenceHandlerImpl

java.lang.Object

org.gytheio.content.handler.AbstractUrlContentReferenceHandler

org.gytheio.content.handler.s3.S3ContentReferenceHandlerImpl

All Implemented Interfaces:

org.gytheio.content.handler.ContentReferenceHandler

public class S3ContentReferenceHandlerImpl
extends org.gytheio.content.handler.AbstractUrlContentReferenceHandler

AWS S3 content handler implementation

Author:

Ray Gauss II, janv

Field Summary

Fields

Modifier and Type	Field and Description
static String	HTTP_PROTOCOL
static String	HTTPS_PROTOCOL
static String	S3_PROTOCOL_DELIMITER
static String	S3_STORE_PROTOCOL store protocol that is used as prefix in contentUrls

Fields inherited from class org.gytheio.content.handler.AbstractUrlContentReferenceHandler

isAvailable, waitForAvailability

Constructor Summary

Constructors

Constructor and Description
S3ContentReferenceHandlerImpl()

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(org.gytheio.content.ContentReference contentReference)
InputStream	getInputStream(org.gytheio.content.ContentReference contentReference, boolean waitForAvailability)
protected String	getRemoteBaseUrl()
String	getS3BucketName()
protected String	getS3UrlFromHttpUrl(String url)
void	init()
static com.amazonaws.services.s3.AmazonS3	initClient(String s3AccessKey, String s3SecretKey, String s3BucketRegion)
boolean	isContentReferenceExists(org.gytheio.content.ContentReference contentReference)
boolean	isContentReferenceSupported(org.gytheio.content.ContentReference contentReference)
long	putFile(File sourceFile, org.gytheio.content.ContentReference targetContentReference)
long	putInputStream(InputStream sourceInputStream, org.gytheio.content.ContentReference targetContentReference)
void	setS3AccessKey(String s3AccessKey)
void	setS3BucketName(String s3BucketName)
void	setS3BucketRegion(String s3BucketLocation)
void	setS3SecretKey(String s3SecretKey)

Methods inherited from class org.gytheio.content.handler.AbstractUrlContentReferenceHandler

createContentReference, createNewUrl, getExtension, getRelativePath, getRemoteFileUrl, getRemotePath, isAvailable

Methods inherited from class java.lang.Object

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

Field Detail

S3_STORE_PROTOCOL

public static final String S3_STORE_PROTOCOL

store protocol that is used as prefix in contentUrls

See Also:

Constant Field Values

S3_PROTOCOL_DELIMITER

public static final String S3_PROTOCOL_DELIMITER

See Also:

Constant Field Values

HTTP_PROTOCOL

public static final String HTTP_PROTOCOL

See Also:

Constant Field Values

HTTPS_PROTOCOL

public static final String HTTPS_PROTOCOL

See Also:

Constant Field Values

Constructor Detail

S3ContentReferenceHandlerImpl

public S3ContentReferenceHandlerImpl()

Method Detail

setS3AccessKey

public void setS3AccessKey(String s3AccessKey)

setS3SecretKey

public void setS3SecretKey(String s3SecretKey)

getS3BucketName

public String getS3BucketName()

setS3BucketName

public void setS3BucketName(String s3BucketName)

setS3BucketRegion

public void setS3BucketRegion(String s3BucketLocation)

init

public void init()

Specified by:

init in class org.gytheio.content.handler.AbstractUrlContentReferenceHandler

initClient

public static com.amazonaws.services.s3.AmazonS3 initClient(String s3AccessKey,
                                            String s3SecretKey,
                                            String s3BucketRegion)

getRemoteBaseUrl

protected String getRemoteBaseUrl()

Specified by:

getRemoteBaseUrl in class org.gytheio.content.handler.AbstractUrlContentReferenceHandler

getS3UrlFromHttpUrl

protected String getS3UrlFromHttpUrl(String url)

isContentReferenceSupported

public boolean isContentReferenceSupported(org.gytheio.content.ContentReference contentReference)

isContentReferenceExists

public boolean isContentReferenceExists(org.gytheio.content.ContentReference contentReference)

getInputStream

public InputStream getInputStream(org.gytheio.content.ContentReference contentReference,
                         boolean waitForAvailability)
                           throws org.gytheio.content.ContentIOException

Throws:

org.gytheio.content.ContentIOException

putFile

public long putFile(File sourceFile,
           org.gytheio.content.ContentReference targetContentReference)
             throws org.gytheio.content.ContentIOException

Throws:

org.gytheio.content.ContentIOException

putInputStream

public long putInputStream(InputStream sourceInputStream,
                  org.gytheio.content.ContentReference targetContentReference)
                    throws org.gytheio.content.ContentIOException

Throws:

org.gytheio.content.ContentIOException

delete

public void delete(org.gytheio.content.ContentReference contentReference)
            throws org.gytheio.content.ContentIOException

Throws:

org.gytheio.content.ContentIOException