|
virtual | ~ISessionStorage () ONIXS_FIXENGINE_DEFAULT |
virtual void | clear ()=0 |
virtual void | close (bool keepSequenceNumbers, bool doBackup)=0 |
virtual void | getOutbound (SequenceNumber beginSequenceNumber, SequenceNumber endSequenceNumber, ISessionStorageListener *listener)=0 |
virtual SequenceNumber | inSeqNum ()=0 |
virtual void | inSeqNum (SequenceNumber messageSequenceNumber)=0 |
virtual void | storeInbound (const Message &message, SequenceNumber sequenceNumber, const RawMessagePointer &pointer, bool logMessage)=0 |
virtual void | storeInbound (const FlatMessage &message, SequenceNumber sequenceNumber, const RawMessagePointer &pointer, bool logMessage)=0 |
virtual void | storeOutbound (const Message &message, const RawMessagePointer &pointer, bool logMessage)=0 |
virtual void | storeOutbound (const FlatMessage &message, SequenceNumber sequenceNumber, const RawMessagePointer &pointer, bool logMessage)=0 |
virtual void | setSessionTerminationFlag (bool terminated)=0 |
virtual SequenceNumber | outSeqNum ()=0 |
virtual void | outSeqNum (SequenceNumber messageSequenceNumber)=0 |
virtual void | sessionCreationTime (Timestamp timestamp)=0 |
virtual Timestamp | sessionCreationTime ()=0 |
virtual void | flush ()=0 |
virtual size_t | resendingQueueSize () const =0 |
virtual void | resendingQueueSize (size_t value)=0 |
virtual void | warmup (size_t) |
Definition at line 33 of file ISessionStorage.h.
◆ ~ISessionStorage()
◆ clear()
◆ close()
virtual void close |
( |
bool | keepSequenceNumbers, |
|
|
bool | doBackup ) |
|
pure virtual |
Closes the storage.
- Parameters
-
keepSequenceNumbers | The flag to indicate if it needs to clear sequence numbers on close or not. It corresponds to the same parameter in the Session's constructor. |
doBackup | The flag to indicate if it needs to back up the stored data. It is true, when the Session::resetLocalSequenceNumbers() method is called. |
◆ flush()
Flushes all internal buffers.
◆ getOutbound()
Gets the messages that have been sent earlier.
The implementation should pass required messages one by one to the ISessionStorageListener::onReplayedMessage(const RawMessagePointer& pointer) method. It is possible to omit some or even all messages in the requested range, in this case the Engine will automatically generate appropriate SequenceReset-GapFill messages to replace omitted ones.
- Parameters
-
beginSequenceNumber | The sequence number of first message to resend. |
endSequenceNumber | the sequence number of last message to resend. |
listener | Requested messages have to be passed to the interface using the ISessionStorageListener::onReplayedMessage method. |
- Note
- The FIX Engine/Session Storage does NOT manage the lifetime of this listener.
◆ inSeqNum() [1/2]
Returns the last inbound sequence number.
◆ inSeqNum() [2/2]
Sets the last inbound sequence number.
◆ outSeqNum() [1/2]
Returns the last outgoing sequence number.
◆ outSeqNum() [2/2]
Sets the last outgoing sequence number.
◆ resendingQueueSize() [1/2]
virtual size_t resendingQueueSize |
( |
| ) |
const |
|
pure virtual |
Returns the number of sent messages that are available for resending on counterparty's Resend Request <2> message.
◆ resendingQueueSize() [2/2]
virtual void resendingQueueSize |
( |
size_t | value | ) |
|
|
pure virtual |
Sets the number of sent messages that are available for resending on counterparty's Resend Request <2> message.
◆ sessionCreationTime() [1/2]
◆ sessionCreationTime() [2/2]
virtual void sessionCreationTime |
( |
Timestamp | timestamp | ) |
|
|
pure virtual |
Sets the session creation time.
The implementation should store the timestamp value. This value have to be returned without changes by subsequent ISessionStorage::sessionCreationTime() calls.
- Parameters
-
timestamp | The timestamp to store in the storage. |
◆ setSessionTerminationFlag()
virtual void setSessionTerminationFlag |
( |
bool | terminated | ) |
|
|
pure virtual |
Sets the session termination flag.
- Parameters
-
terminated | If 'true' then the session is terminated and its state information is not needed any more. It happens when the session is disconnected gracefully, and the keepSequenceNumbers parameter is false. |
◆ storeInbound() [1/2]
Stores the given inbound message.
- Parameters
-
message | The incoming message. |
sequenceNumber | The sequence number of the inbound message. |
pointer | The raw buffer of the inbound message. |
logMessage | The flag to indicate whether it needs to store the content of the message in the session storage or not. This parameter depends on the Session::logInboundMessages() and Session::inboundMessageLogFilter() settings. |
◆ storeInbound() [2/2]
Stores the given inbound message.
- Parameters
-
message | The incoming message. |
sequenceNumber | The sequence number of the inbound message. |
pointer | The raw buffer of the inbound message. |
logMessage | The flag to indicate whether it needs to store the content of the message in the session storage or not. This parameter depends on the Session::logInboundMessages() and Session::inboundMessageLogFilter() settings. |
◆ storeOutbound() [1/2]
Stores the given outgoing message.
It is called when the messageMode is set to FlatMessage.
- Parameters
-
message | The outgoing message. |
sequenceNumber | The sequence number of the outgoing message. |
pointer | The raw buffer of the outgoing message. |
logMessage | The flag to indicate whether it needs to store the content of the message in the session storage or not. This parameter depends on the Session::logOutboundMessages() and Session::outboundMessageLogFilter() settings. |
◆ storeOutbound() [2/2]
Stores the given outgoing message.
It is called when the messageMode is set to Message.
- Parameters
-
◆ warmup()
virtual void warmup |
( |
size_t | | ) |
|
|
inlinevirtual |