com.epam.fixengine.jms.storage.queue

Class InMemoryQueue

java.lang.Object

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

All Implemented Interfaces:

IQueue

Direct Known Subclasses:

PersistentInMemoryQueue

public class InMemoryQueue
extends Object
implements IQueue

Constructor Summary

Constructors

Constructor and Description
InMemoryQueue(int capacity, long publishTimeout)

Method Summary

Modifier and Type	Method and Description
void	add(FIXFieldList fixMessage) add message to queue.
protected void	addRestored(int seqNum, byte[] data)
void	clear() Atomically removes all of the elements from this queue.
void	commit(IQueueable object) Removes polled object from the queue.
void	commit(IQueueable[] batchItems, int size) Removes polled objects from the queue.
void	failedProcessing(IQueueable object) Return element to queue.
void	failedProcessing(IQueueable[] batchItems, int size) Return element to queue.
void	initialize() Initializes queue.
boolean	isEmpty() Checks if queue is currently empty.
protected boolean	isEmptyInner() Check is empty without lock
protected void	onCommit(IQueueable x)
protected void	onInsert(IQueueable x)
IQueueable	poll() Poll object from the queue (doesn't remove it from queue yet!).
protected void	resetSeqNum()
protected void	setSeqNum(int seqNum)
void	shutdown() Gracefully shutdowns queue.
int	size() Returns the number of elements in this queue.
IQueueable	take() Retrieves and mark as processing the head of this queue, waiting if necessary until an element becomes available.
int	take(IQueueable[] batch) Retrieves and mark as processing the batch elements from head of this queue, waiting if necessary until at least one element becomes available.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryQueue

public InMemoryQueue(int capacity,
                     long publishTimeout)

Method Detail

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

Throws:

IOException

See Also:

IQueue.initialize()

size

public int size()

Returns the number of elements in this queue.

Specified by:

size in interface IQueue

Returns:

the number of elements in this queue

isEmpty

public boolean isEmpty()

Description copied from interface: IQueue

Checks if queue is currently empty.

Specified by:

isEmpty in interface IQueue

Returns:

true if empty

See Also:

IQueue.isEmpty()

isEmptyInner

protected boolean isEmptyInner()

Check is empty without lock

Returns:

add

public void add(FIXFieldList fixMessage)
         throws InterruptedException,
                IOException

Description copied from interface: IQueue

add message to queue.

Specified by:

add in interface IQueue

Throws:

InterruptedException

IOException

poll

public IQueueable poll()

Description copied from interface: IQueue

Poll object from the queue (doesn't remove it from queue yet!). Change tem state to processing.

Specified by:

poll in interface IQueue

Returns:

the head of this queue, or null if this queue is empty

See Also:

IQueue.poll()

take

public IQueueable take()

Retrieves and mark as processing the head of this queue, waiting if necessary until an element becomes available.

Specified by:

take in interface IQueue

Returns:

the head of this queue

Throws:

IllegalStateException - if interrupted while waiting

take

public int take(IQueueable[] batch)

Description copied from interface: IQueue

Retrieves and mark as processing the batch elements from head of this queue, waiting if necessary until at least one element becomes available.

Specified by:

take in interface IQueue

Returns:

the number of read elements

failedProcessing

public void failedProcessing(IQueueable object)

Description copied from interface: IQueue

Return element to queue. Item will be available again for handing.

Specified by:

failedProcessing in interface IQueue

failedProcessing

public void failedProcessing(IQueueable[] batchItems,
                             int size)

Description copied from interface: IQueue

Return element to queue. Items will be available again for handing.

Specified by:

failedProcessing in interface IQueue

size - the number of items in batch

commit

public void commit(IQueueable object)
            throws IOException

Description copied from interface: IQueue

Removes polled object from the queue.

Specified by:

commit in interface IQueue

Throws:

IOException

See Also:

IQueue.commit(IQueueable object)

commit

public void commit(IQueueable[] batchItems,
                   int size)
            throws IOException

Description copied from interface: IQueue

Removes polled objects from the queue.

Specified by:

commit in interface IQueue

size - the number of items in batch

Throws:

IOException

clear

public void clear()
           throws IOException

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

Specified by:

clear in interface IQueue

Throws:

IOException

shutdown

public void shutdown()

Description copied from interface: IQueue

Gracefully shutdowns queue.

Specified by:

shutdown in interface IQueue

See Also:

IQueue.shutdown()

resetSeqNum

protected void resetSeqNum()

setSeqNum

protected void setSeqNum(int seqNum)

addRestored

protected void addRestored(int seqNum,
                           byte[] data)

onInsert

protected void onInsert(IQueueable x)
                 throws IOException

Throws:

IOException

onCommit

protected void onCommit(IQueueable x)
                 throws IOException

Throws:

IOException