#include <OnixS/FIXEngine/FIX/ISessionStorage.h>
|
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.
virtual void close |
( |
bool |
keepSequenceNumbers, |
|
|
bool |
doBackup |
|
) |
| |
|
pure virtual |
Closes the storage.
- Parameters
-
keepSequenceNumbers | 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 | Flag to indicate if it needs to back up the stored data. It is true, when the Session::resetLocalSequenceNumbers() method is called. |
Flushes all internal buffers.
Gets the messages that have been sent earlier.
Implementation should pass required messages one by one to ISessionStorageListener::onReplayedMessage(const RawMessagePointer& pointer) method. It is possible to omit some or even all messages in requested range, in this case the Engine will automatically generate appropriate SequenceReset-GapFill messages to replace omitted ones.
- Parameters
-
beginSequenceNumber | Sequence number of first message to resend. |
endSequenceNumber | Sequence number of last message to resend. |
listener | Requested messages have to be passed to the interface using ISessionStorageListener::onReplayedMessage method. |
- Note
- FIX Engine/Session Storage does NOT manage the lifetime of this listener.
Returns the last inbound sequence number.
Sets the last inbound sequence number.
Returns the last outgoing sequence number.
Sets the last outgoing sequence number.
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.
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.
virtual void sessionCreationTime |
( |
Timestamp |
timestamp | ) |
|
|
pure virtual |
Sets session creation time.
Implementation should store timestamp value. This value have to be returned without changes by subsequent ISessionStorage::sessionCreationTime() calls.
- Parameters
-
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. |
Stores the given inbound message.
- Parameters
-
message | Incoming message. |
sequenceNumber | Sequence number of the inbound message. |
pointer | Raw buffer of the inbound message. |
logMessage | 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. |
Stores the given inbound message.
- Parameters
-
message | Incoming message. |
sequenceNumber | Sequence number of the inbound message. |
pointer | Raw buffer of the inbound message. |
logMessage | 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. |
Stores the given outgoing message.
It is called when the messageMode
is set to Message
.
- Parameters
-
Stores the given outgoing message.
It is called when the messageMode
is set to FlatMessage
.
- Parameters
-
message | Outgoing message. |
sequenceNumber | Sequence number of the outgoing message. |
pointer | Raw buffer of the outgoing message. |
logMessage | 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. |
virtual void warmup |
( |
size_t |
| ) |
|
|
inlinevirtual |
The documentation for this class was generated from the following file: