biz.onixs.fix.engine.storage

Class FileBasedStorageRepository

java.lang.Object

biz.onixs.fix.engine.storage.AbstractStorageRepository

biz.onixs.fix.engine.storage.FileBasedStorageRepository

All Implemented Interfaces:

StorageRepository

public class FileBasedStorageRepository
extends AbstractStorageRepository

Repository of file-based session storage.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FileBasedStorageRepository.LogCleanupVisitor

Constructor Summary

Constructors

Constructor and Description
FileBasedStorageRepository(ExclusiveLockProvider exclusiveLockProvider)

Method Summary

Modifier and Type	Method and Description
SessionStorage	create(SessionId sessionId, boolean cleanStart) Creates session storage from scratch or restores from its previous state.
int	getCleanUpOldLogs() Returns the number of days back older storage files will be deleted.
long	getRotateStorageSize() Returns the size at which the storage file is rotated.
String	getStorageFolder() Returns the storage folder.
boolean	isArchiveStorage() Returns whether to archive terminated storage.
boolean	isFlushPerMessage() Returns whether each message is flushed individually to the storage.
void	setArchiveStorage(boolean archiveStorage) Sets whether to archive terminated storage.
void	setCleanUpOldLogs(int daysBack) Sets the number of days back older storage files will be deleted.
void	setFlushPerMessage(boolean flushPerMessage) Sets whether each message should be flushed individually to the storage.
void	setRotateStorageSize(long rotateStorageSize) Sets the size at which the storage file is rotated.
void	setStorageFolder(String storageFolder) Sets the storage folder.
String	toString()

Methods inherited from class biz.onixs.fix.engine.storage.AbstractStorageRepository

getMaxStorageSize, setMaxStorageSize

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FileBasedStorageRepository

public FileBasedStorageRepository(ExclusiveLockProvider exclusiveLockProvider)

Method Detail

isArchiveStorage

public boolean isArchiveStorage()

Returns whether to archive terminated storage.

Returns:

archive terminated storage

setArchiveStorage

public void setArchiveStorage(boolean archiveStorage)

Sets whether to archive terminated storage.

Parameters:

archiveStorage - archive terminated storage

getRotateStorageSize

public long getRotateStorageSize()

Returns the size at which the storage file is rotated.

Returns:

storage rotation size, in bytes

setRotateStorageSize

public void setRotateStorageSize(long rotateStorageSize)

Sets the size at which the storage file is rotated.

Parameters:

rotateStorageSize - storage rotation size, in bytes

getCleanUpOldLogs

public int getCleanUpOldLogs()

Returns the number of days back older storage files will be deleted.
Please note that the file's LastModifiedTime attribute is considered while checking whether file is old.

Returns:

the number of days back.

setCleanUpOldLogs

public void setCleanUpOldLogs(int daysBack)

Sets the number of days back older storage files will be deleted.
Please note that it may cause seq. number reset in case the last storage files are old too.
Please note that the file's LastModifiedTime attribute is considered while checking whether file is old.

Parameters:

daysBack - the number of days back(by default it is set to Integer.MAX_VALUE to not perform cleanup at all).

getStorageFolder

public String getStorageFolder()

Returns the storage folder.

Returns:

storage folder

setStorageFolder

public void setStorageFolder(String storageFolder)

Sets the storage folder.

Parameters:

storageFolder - storage folder

isFlushPerMessage

public boolean isFlushPerMessage()

Returns whether each message is flushed individually to the storage.
Flushing per message ensures that data is persisted immediately, which can improve reliability at the cost of performance.

Returns:

true if each message is flushed individually, otherwise false

setFlushPerMessage

public void setFlushPerMessage(boolean flushPerMessage)

Sets whether each message should be flushed individually to the storage.
Flushing per message ensures that data is persisted immediately, which can improve reliability at the cost of performance.

Parameters:

flushPerMessage - true if each message should be flushed individually, otherwise false

create

public SessionStorage create(SessionId sessionId,
                             boolean cleanStart)

Description copied from interface: StorageRepository

Creates session storage from scratch or restores from its previous state.

Parameters:

sessionId - session id

cleanStart - clean previous session state if any

Returns:

session storage

toString

public String toString()

Overrides:

toString in class Object