public class MMFPersistentInMemoryQueue<T extends Queueable> extends InMemoryQueue<T> implements Queue<T>
| Modifier and Type | Field and Description |
|---|---|
protected RandomAccessFile |
accessFile |
protected ByteBuffer |
buffer |
protected FileChannel |
channel |
protected boolean |
isForcedFlush |
application, log, maskedTags, session| Constructor and Description |
|---|
MMFPersistentInMemoryQueue(String filename,
QueueableFactory<T> factory)
Deprecated.
|
MMFPersistentInMemoryQueue(String filename,
QueueableFactory<T> factory,
com.epam.fixengine.configuration.Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
add(T element)
Add object to the queue.
|
void |
clear()
Clears the queue.
|
protected void |
clearAndNormalizeFile() |
void |
commit()
Removes polled object from the queue.
|
void |
initialize()
Initializes queue.
|
void |
shutdown()
Gracefully shutdowns queue.
|
addOutOfTurn, clearOutOfTurn, isAllEmpty, isApplicationCommit, isEmpty, isOutOfTurnOnlyMode, isShutdown, notifyAllApplication, notifyAllSession, poll, setOutOfTurnOnlyMode, size, toArray, totalSizeclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddOutOfTurn, clearOutOfTurn, isAllEmpty, isEmpty, isOutOfTurnOnlyMode, notifyAllApplication, notifyAllSession, poll, setOutOfTurnOnlyMode, size, toArray, totalSizeprotected FileChannel channel
protected RandomAccessFile accessFile
protected ByteBuffer buffer
protected boolean isForcedFlush
@Deprecated public MMFPersistentInMemoryQueue(String filename, QueueableFactory<T> factory)
public MMFPersistentInMemoryQueue(String filename, QueueableFactory<T> factory, com.epam.fixengine.configuration.Configuration conf)
public void initialize()
Queueinitialize in interface Queue<T extends Queueable>initialize in class InMemoryQueue<T extends Queueable>Queue.initialize()public void commit()
Queuecommit in interface Queue<T extends Queueable>commit in class InMemoryQueue<T extends Queueable>Queue.commit()public boolean add(T element)
Queueadd in interface Queue<T extends Queueable>add in class InMemoryQueue<T extends Queueable>element - the elementQueue.add(Queueable)public void clear()
Queueclear in interface Queue<T extends Queueable>clear in class InMemoryQueue<T extends Queueable>Queue.clear()protected void clearAndNormalizeFile()
public void shutdown()
Queueshutdown in interface Queue<T extends Queueable>shutdown in class InMemoryQueue<T extends Queueable>Queue.shutdown()Copyright © 2000–2022 EPAM Systems. All rights reserved.