Package com.avoka.fc.core.service.impl

Class S3TransactionHistoryPublisher

java.lang.Object

com.avoka.fc.core.service.BaseService

com.avoka.fc.core.service.impl.S3TransactionHistoryPublisher

All Implemented Interfaces:

IServiceDefinitionAware, ITransactionHistoryPublisher

public class S3TransactionHistoryPublisher
extends BaseService

Publish transaction history records to the AWS S3 object store.

Since:

5.1.0

Constructor Summary

Constructors

Constructor	Description
S3TransactionHistoryPublisher()

Method Summary

Modifier and Type	Method	Description
int	getFetchLimit()	Return the fetch limit to limit the maximum number of published records.
String	getFileFormat()	Set fileFormat.
String	getFormat()	Set format.
Boolean	getGzipCompress()	Return gzipCompress
ServiceDefinition	getServiceDefinition()	Return the service definition for the service.
protected void	publish(String fileName, byte[] data)	Publish transaction history data with the given file name.
List<Number>	publish(List<Map<String,Object>> rows)	Perform transaction history publishing.
void	setFetchLimit(int fetchLimit)	Set the fetch limit to limit the maximum number of published records.
void	setFileFormat(String fileFormat)	Return the file format.
void	setFormat(String format)	Return the format.
void	setGzipCompress(Boolean gzipCompress)	Set gzipCompress
void	setServiceDefinition(ServiceDefinition serviceDefinition)	Set the service definition for the service.

Methods inherited from class com.avoka.fc.core.service.BaseService

getLogger

Methods inherited from class java.lang.Object

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

Constructor Detail

S3TransactionHistoryPublisher

public S3TransactionHistoryPublisher()

Method Detail

publish

protected void publish(String fileName,
                       byte[] data)

Publish transaction history data with the given file name.

Parameters:

fileName - file name.

data - transaction history data as byte array.

See Also:

AbstractTransactionHistoryPublisher.publish(String, byte[])

publish

public final List<Number> publish(List<Map<String,Object>> rows)

Description copied from interface: ITransactionHistoryPublisher

Perform transaction history publishing.

Specified by:

publish in interface ITransactionHistoryPublisher

Parameters:

rows - list of rows to publish

Returns:

list of id-s of the published records

getFetchLimit

public int getFetchLimit()

Return the fetch limit to limit the maximum number of published records.

Specified by:

getFetchLimit in interface ITransactionHistoryPublisher

Returns:

the fetch limit to limit the maximum number of published records

setFetchLimit

public void setFetchLimit(int fetchLimit)

Set the fetch limit to limit the maximum number of published records.

Parameters:

fetchLimit - the fetch limit to limit the maximum number of published records

getFormat

public String getFormat()

Set format.

Returns:

the format

setFormat

public void setFormat(String format)

Return the format.

Parameters:

format - the format to set

getGzipCompress

public Boolean getGzipCompress()

Return gzipCompress

Returns:

the gzipCompress

setGzipCompress

public void setGzipCompress(Boolean gzipCompress)

Set gzipCompress

Parameters:

gzipCompress - the gzipCompress

getFileFormat

public String getFileFormat()

Set fileFormat.

Returns:

the fileFormat

setFileFormat

public void setFileFormat(String fileFormat)

Return the file format.

Parameters:

fileFormat - the fileFormat to set

getServiceDefinition

public ServiceDefinition getServiceDefinition()

Return the service definition for the service.

Specified by:

getServiceDefinition in interface IServiceDefinitionAware

Returns:

the service definition for the service.

See Also:

IServiceDefinitionAware.getServiceDefinition()

setServiceDefinition

public void setServiceDefinition(ServiceDefinition serviceDefinition)

Set the service definition for the service.

Specified by:

setServiceDefinition in interface IServiceDefinitionAware

Parameters:

serviceDefinition - the service definition for the service.

See Also:

IServiceDefinitionAware.setServiceDefinition(ServiceDefinition)