OnixS C++ FIX Engine  4.10.1
API Documentation
Pluggable Session Storage

Pluggable session storage is the storage which implemented by the user. For example, it could be used to implement High-Availability (HA) Solutions. One can implement a Pluggable Session Storage, which stores data to shareable storage. If one server with the FIX Engine fails and another reserve server stands up, the FIX Engine can restore session states from the same shareable storage. Such storage should implement the OnixS::FIX::ISessionStorage interface.

Implementing Pluggable Storage

There are few basic rules that should be applied to the implementation of Pluggable Storage.

Call Order of Pluggable Storage Methods

This section explains how different methods of Pluggable Storage are called in different situations.

Incoming message handling

If an exception is thrown by the user's code on any stage (during ISessionStorage or ISessionListener handling), the session becomes disconnected, and subsequent stages are omitted. Logout message will be sent to the counterparty in dependency on the value of the OnixS::FIX::EngineSettings::sendLogoutOnException setting.

Outgoing message handling

Note
If a message is sent from the OnixS::FIX::ISessionListener::onInboundApplicationMsg() callback, the session checks it and calls the OnixS::FIX::ISessionStorage::storeInbound() first before calling the OnixS::FIX::ISessionStorage::storeOutbound(). The session does it to keep the logging order. Otherwise, the OnixS::FIX::ISessionStorage::storeOutbound() will be called before the OnixS::FIX::ISessionStorage::storeInbound(), and the outbound message will appear in the log before the inbound message.

Resend Request handling

Attaching Pluggable Storage

There is a quite schematic illustration for the pluggable storage usage.

// Declare the own class and implement ISessionStorage interface callbacks.
class MyPluggableStorage : public OnixS::FIX::ISessionStorage
{
public:
void clear() ONIXS_FIXENGINE_OVERRIDE {}
void close(bool /*keepSequenceNumbers*/, bool /*doBackup*/) ONIXS_FIXENGINE_OVERRIDE {}
void getOutbound(SequenceNumber /*beginSequenceNumber*/, SequenceNumber /*endSequenceNumber*/, ISessionStorageListener * /*listener*/) ONIXS_FIXENGINE_OVERRIDE {}
SequenceNumber inSeqNum() ONIXS_FIXENGINE_OVERRIDE { return 0; }
void inSeqNum(SequenceNumber /*messageSequenceNumber*/) ONIXS_FIXENGINE_OVERRIDE {}
void storeInbound(const Message &, SequenceNumber /*messageSequenceNumber*/, const RawMessagePointer & /*pointer*/, bool /*logMessage*/) ONIXS_FIXENGINE_OVERRIDE {}
void storeInbound(const FlatMessage &, SequenceNumber /*messageSequenceNumber*/, const RawMessagePointer& /*pointer*/, bool /*logMessage*/) ONIXS_FIXENGINE_OVERRIDE {}
void storeOutbound(const Message &, const RawMessagePointer & /*pointer*/, bool /*logMessage*/) ONIXS_FIXENGINE_OVERRIDE {}
void storeOutbound(const FlatMessage &, SequenceNumber /*sequenceNumber*/, const RawMessagePointer & /*pointer*/, bool /*logMessage*/) ONIXS_FIXENGINE_OVERRIDE {}
void setSessionTerminationFlag(bool /*terminated*/) ONIXS_FIXENGINE_OVERRIDE {}
SequenceNumber outSeqNum() ONIXS_FIXENGINE_OVERRIDE { return 0; }
void outSeqNum(SequenceNumber /*messageSequenceNumber*/) ONIXS_FIXENGINE_OVERRIDE {}
void sessionCreationTime(Timestamp) ONIXS_FIXENGINE_OVERRIDE {}
Timestamp sessionCreationTime() ONIXS_FIXENGINE_OVERRIDE { return Timestamp(); }
void flush() ONIXS_FIXENGINE_OVERRIDE {}
size_t resendingQueueSize() const ONIXS_FIXENGINE_OVERRIDE { return 1000; }
void resendingQueueSize(size_t) ONIXS_FIXENGINE_OVERRIDE {}
};
// Declare the instance of the storage.
MyPluggableStorage myStorage;
// Create the session which uses the storage.
Session initiator("SenderCompId", "TargetCompId", ProtocolVersion::FIX_42, &listener, SessionStorageType::Pluggable, &myStorage);

Example

Please, check the Pluggable Storage Sample included in the distribution package of the FIX Engine.