Package com.epam.fixengine.storage

Interface StorageFactory

All Known Implementing Classes:
ChronicleStorageFactory, FilesystemStorageFactory, InMemoryStorageFactory, MMFStorageFactory, SlicedFileStorageFactory
public interface StorageFactory
Base storage factory interface. Provides ability to create incoming and outgoing storage. To replace the standard implementation, use a storageFactory parameter in properties file.

  • Method Details

    • getIncomingMessageStorage

      MessageStorage getIncomingMessageStorage(SessionParameters sessionParameters)
      Get incoming message storage instance.
      Parameters:
      sessionParameters - session parameters
      Returns:
      the incoming message storage

    • getOutgoingMessageStorage

      MessageStorage getOutgoingMessageStorage(SessionParameters sessionParameters)
      Get outgoing message storage instance.
      Parameters:
      sessionParameters - session parameters
      Returns:
      the outgoing message storage

    • saveSessionParameters

      void saveSessionParameters(SessionParameters sessionParameters, FIXSessionRuntimeState state) throws IOException
      Save session parameters.
      Parameters:
      sessionParameters - session parameters
      Throws:
      IOException - - if error occurred

    • loadSessionParameters

      boolean loadSessionParameters(SessionParameters sessionParameters, FIXSessionRuntimeState state)
      Save session parameters.
      Parameters:
      sessionParameters - session parameters
      Returns:
      true if parameters loaded

    • getQueue

      Queue<FIXFieldListWithType> getQueue(SessionParameters sessionParameters)
      Get outgoing message queue.
      Parameters:
      sessionParameters - session parameters
      Returns:
      the outgoing queue of messages