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

Class ChroniclePersistentQueue

java.lang.Object

com.epam.fixengine.jms.storage.queue.ChroniclePersistentQueue

All Implemented Interfaces:

IQueue

public class ChroniclePersistentQueue
extends Object
implements IQueue

Constructor Summary

Constructors

Constructor	Description
ChroniclePersistentQueue(String storageDir, String sessionID)
ChroniclePersistentQueue(String storageDir, String sessionID, net.openhft.chronicle.queue.RollCycle rollCycle)

Method Summary

Modifier and Type	Method	Description
void	add(byte[] itemBody)	add message to queue.
void	add(byte[] itemBody, String jmsMessageParams)	add message to queue.
void	clear()	Clears the queue.
void	commit(IQueueable item)	Removes polled object from the queue.
void	commit(IQueueable[] batchItems, int size)	Removes polled objects from the queue.
void	failedProcessing(IQueueable item)	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 void	onCommit(IQueueable x)
protected void	onInsert(IQueueable x)
IQueueable	poll()	Poll object from the queue (doesn't remove it from queue yet!).
void	shutdown()	Gracefully shutdowns queue.
int	size()	Returns current queue size.
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 Details

ChroniclePersistentQueue

public ChroniclePersistentQueue(String storageDir,
 String sessionID)

ChroniclePersistentQueue

public ChroniclePersistentQueue(String storageDir,
 String sessionID,
 net.openhft.chronicle.queue.RollCycle rollCycle)

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

Throws:

IOException

add

public void add(byte[] itemBody)
         throws InterruptedException,
IOException

Description copied from interface: IQueue

add message to queue.

Specified by:

add in interface IQueue

Throws:

InterruptedException

IOException

add

public void add(byte[] itemBody,
 String jmsMessageParams)
         throws InterruptedException,
IOException

Description copied from interface: IQueue

add message to queue.

Specified by:

add in interface IQueue

Throws:

InterruptedException

IOException

onInsert

protected void onInsert(IQueueable x)

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.commit(com.epam.fixengine.jms.storage.queue.IQueueable)

take

public IQueueable take()

Description copied from interface: IQueue

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

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 item)

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 item)
            throws IOException

Description copied from interface: IQueue

Removes polled object from the queue.

Specified by:

commit in interface IQueue

Throws:

IOException

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

onCommit

protected void onCommit(IQueueable x)

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

size

public int size()

Description copied from interface: IQueue

Returns current queue size.

Specified by:

size in interface IQueue

Returns:

queue size

clear

public void clear()
           throws IOException

Description copied from interface: IQueue

Clears the queue.

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