Package com.epam.fixengine.jms.storage.queue

Class PersistentInMemoryQueue

java.lang.Object

com.epam.fixengine.jms.storage.queue.InMemoryQueue

com.epam.fixengine.jms.storage.queue.PersistentInMemoryQueue

All Implemented Interfaces:

IQueue

public class PersistentInMemoryQueue
extends InMemoryQueue

Implementation of persist queue.

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	DEBUG_ENABLED
protected boolean	isForcedFlush
protected Map<byte[],Set<Integer>>	maskedTags
static final long	MAX_FILE_SIZE
static final long	NORMAL_FILE_SIZE

Constructor Summary

Constructors

Constructor	Description
PersistentInMemoryQueue(int capacity, String filename, long publishTimeout)

Method Summary

Modifier and Type	Method	Description
void	clear()	Atomically removes all of the elements from this queue.
void	initialize()	Initializes queue.
void	onCommit(IQueueable item)
protected void	onInsert(IQueueable item)
protected static int	readInt(byte[] raw, int startPoss)
void	setForcedFlush(boolean isForcedFlush)
void	setMaskedTags(Map<byte[],Set<Integer>> maskedTags)
void	setMaxFileSize(long maxFileSize)
void	setNormalFileSize(long normalFileSize)
void	shutdown()	Gracefully shutdowns queue.

Methods inherited from class com.epam.fixengine.jms.storage.queue.InMemoryQueue

add, add, addRestored, commit, commit, failedProcessing, failedProcessing, isEmpty, isEmptyInner, poll, resetSeqNum, setSeqNum, size, take, take

Methods inherited from class java.lang.Object

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

Field Details

DEBUG_ENABLED

public static final boolean DEBUG_ENABLED

NORMAL_FILE_SIZE

public static final long NORMAL_FILE_SIZE

See Also:

• Constant Field Values

MAX_FILE_SIZE

public static final long MAX_FILE_SIZE

See Also:

• Constant Field Values

maskedTags

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

isForcedFlush

protected boolean isForcedFlush

Constructor Details

PersistentInMemoryQueue

public PersistentInMemoryQueue(int capacity,
 String filename,
 long publishTimeout)

Method Details

initialize

public void initialize()
                throws IOException

Description copied from interface: IQueue

Initializes queue. That includes restore of previously saved queue content for persistent queues.

Specified by:

initialize in interface IQueue

Overrides:

initialize in class InMemoryQueue

Throws:

IOException

See Also:

• IQueue.initialize()

setNormalFileSize

public void setNormalFileSize(long normalFileSize)

setMaxFileSize

public void setMaxFileSize(long maxFileSize)

setMaskedTags

public void setMaskedTags(Map<byte[],Set<Integer>> maskedTags)

setForcedFlush

public void setForcedFlush(boolean isForcedFlush)

onInsert

protected void onInsert(IQueueable item)
                 throws IOException

Overrides:

onInsert in class InMemoryQueue

Throws:

IOException

onCommit

public void onCommit(IQueueable item)
              throws IOException

Overrides:

onCommit in class InMemoryQueue

Throws:

IOException

clear

public void clear()
           throws IOException

Description copied from class: InMemoryQueue

Atomically removes all of the elements from this queue. The queue will be empty after this call returns.

Specified by:

clear in interface IQueue

Overrides:

clear in class InMemoryQueue

Throws:

IOException

readInt

protected static int readInt(byte[] raw,
 int startPoss)

shutdown

public void shutdown()

Description copied from interface: IQueue

Gracefully shutdowns queue.

Specified by:

shutdown in interface IQueue

Overrides:

shutdown in class InMemoryQueue

See Also:

• IQueue.shutdown()