Package | Description |
---|---|
com.epam.fixengine.session | |
com.epam.fixengine.storage | |
com.epam.fixengine.storage.queue |
Modifier and Type | Field and Description |
---|---|
protected Queue<FIXFieldListWithType> |
AbstractFIXSession.queue |
Modifier and Type | Method and Description |
---|---|
Queue<FIXFieldListWithType> |
ExtendedFIXSession.getMessageQueue()
Gets internal message queue.
|
Queue<FIXFieldListWithType> |
AbstractFIXSession.getMessageQueue() |
Modifier and Type | Method and Description |
---|---|
Queue<FIXFieldListWithType> |
FilesystemStorageFactory.getQueue(SessionParameters sessionParameters)
Gets queue for session.
|
Queue<FIXFieldListWithType> |
MMFStorageFactory.getQueue(SessionParameters sessionParameters)
Gets queue for session.
|
Queue<FIXFieldListWithType> |
InMemoryStorageFactory.getQueue(SessionParameters sessionParameters)
Create and return a InMemoryQueue instance.
|
Queue<FIXFieldListWithType> |
StorageFactory.getQueue(SessionParameters sessionParameters)
Get outgoing message queue.
|
Modifier and Type | Class and Description |
---|---|
class |
InMemoryQueue<T extends Queueable>
Memory queue implementation.
|
class |
MMFPersistentInMemoryQueue<T extends Queueable>
User: Mykhailo_Sereda
Date: 22.05.12
Time: 17:03
|
class |
PersistentInMemoryQueue<T extends Queueable>
Persistent queue file format is the following:
1 byte record length length [n];
n bytes record length [m]
m bytes record itself
DELETE marker is byte == (byte)0;
|
Copyright © 2000–2022 EPAM Systems. All rights reserved.