com.epam.fixengine.jms.storage

Class FileSystemStorageFactory

java.lang.Object

com.epam.fixengine.jms.storage.FileSystemStorageFactory

All Implemented Interfaces:

IQueueFactory

public class FileSystemStorageFactory
extends Object
implements IQueueFactory

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_DIR
static String	DEFAULT_QUEUE_TEMPLATE
protected boolean	isForcedFlush
protected Map<byte[],Set<Integer>>	maskedTags
protected long	maxFileSize
protected long	normalFileSize
protected long	publishTimeout
protected ILogFileLocator	queueFileLocator
protected int	queueSize

Constructor Summary

Constructors

Constructor and Description
FileSystemStorageFactory(String storageDir, int queueSize, long publishTimeout) Creates the FileSystemStorageFactory storage.

Method Summary

Modifier and Type	Method and Description
IQueue	getQueue(String sessionID) Gets queue for session.
ILogFileLocator	getQueueFileLocator()
void	setForcedFlush(boolean isForcedFlush)
void	setMaskPasswordsInStorages(Map<byte[],Set<Integer>> maskPasswordsInStorages)
void	setMaxFileSize(long maxFileSize)
void	setNormalFileSize(long normalFileSize)
void	setQueueFileLocator(ILogFileLocator queueFileLocator)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_QUEUE_TEMPLATE

public static final String DEFAULT_QUEUE_TEMPLATE

See Also:

Constant Field Values

DEFAULT_DIR

public static final String DEFAULT_DIR

See Also:

Constant Field Values

queueFileLocator

protected ILogFileLocator queueFileLocator

queueSize

protected int queueSize

normalFileSize

protected long normalFileSize

maxFileSize

protected long maxFileSize

publishTimeout

protected long publishTimeout

maskedTags

protected Map<byte[],Set<Integer>> maskedTags

isForcedFlush

protected boolean isForcedFlush

Constructor Detail

FileSystemStorageFactory

public FileSystemStorageFactory(String storageDir,
                                int queueSize,
                                long publishTimeout)

Creates the FileSystemStorageFactory storage.

Method Detail

setNormalFileSize

public void setNormalFileSize(long normalFileSize)

setMaxFileSize

public void setMaxFileSize(long maxFileSize)

setMaskPasswordsInStorages

public void setMaskPasswordsInStorages(Map<byte[],Set<Integer>> maskPasswordsInStorages)

setForcedFlush

public void setForcedFlush(boolean isForcedFlush)

setQueueFileLocator

public void setQueueFileLocator(ILogFileLocator queueFileLocator)

getQueueFileLocator

public ILogFileLocator getQueueFileLocator()

getQueue

public IQueue getQueue(String sessionID)

Gets queue for session. If parameter inMemoryQueue configured, the queue will be InMemoryQueue, otherwise PersistentInMemoryQueue.

Specified by:

getQueue in interface IQueueFactory

Parameters:

sessionID -