Package com.avoka.fc.core.service.impl
Class FileSystemTransactionHistoryPublisher
- java.lang.Object
-
- com.avoka.fc.core.service.BaseService
-
- com.avoka.fc.core.service.impl.FileSystemTransactionHistoryPublisher
-
- All Implemented Interfaces:
IServiceDefinitionAware
,ITransactionHistoryPublisher
public class FileSystemTransactionHistoryPublisher extends BaseService
Publish transaction history records to a file system directory.- Since:
- 5.1.0
-
-
Constructor Summary
Constructors Constructor Description FileSystemTransactionHistoryPublisher()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description int
getFetchLimit()
Return the fetch limit to limit the maximum number of published records.String
getFileFormat()
Set fileFormat.String
getFileSystemDir()
Get file system directory where transaction history is stored.String
getFormat()
Set format.Boolean
getGzipCompress()
Return gzipCompressServiceDefinition
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
setFileSystemDir(String fileSystemDir)
Set file system directory where transaction history is stored.void
setFormat(String format)
Return the format.void
setGzipCompress(Boolean gzipCompress)
Set gzipCompressvoid
setServiceDefinition(ServiceDefinition serviceDefinition)
Set the service definition for the service.-
Methods inherited from class com.avoka.fc.core.service.BaseService
getLogger
-
-
-
-
Method Detail
-
getFileSystemDir
public String getFileSystemDir()
Get file system directory where transaction history is stored.- Returns:
- the fileSystemDir
-
setFileSystemDir
public void setFileSystemDir(String fileSystemDir)
Set file system directory where transaction history is stored.- Parameters:
fileSystemDir
- file system directory where transaction history is stored.
-
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 interfaceITransactionHistoryPublisher
- 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 interfaceITransactionHistoryPublisher
- 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 interfaceIServiceDefinitionAware
- 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 interfaceIServiceDefinitionAware
- Parameters:
serviceDefinition
- the service definition for the service.- See Also:
IServiceDefinitionAware.setServiceDefinition(ServiceDefinition)
-
-