35using namespace OnixS::CME::ConflatedTCP::Messaging;
73 virtual const std::
string &
id() const = 0;
130 virtual
void close(
bool terminate = false,
bool doBackup = false) = 0;
#define ONIXS_CONFLATEDTCP_EXPORTED
#define ONIXS_CONFLATEDTCP_NULLPTR
#define ONIXS_CONFLATEDTCP_DEFAULT
The time point without the time-zone information.
virtual bool terminated() const =0
virtual void flush()=0
Flushes all internal buffers.
virtual void clear()=0
Clears the storage.
virtual UInt64 previousUuid() const =0
virtual UInt64 uuid() const =0
virtual ~SessionStorage()=default
Destructor.
virtual void close(bool terminate=false, bool doBackup=false)=0
Closes the storage.
virtual SeqNumber inSeqNum() const =0
virtual void storeOutboundMessage(const RawMessagePointer &rawMsg, SeqNumber msgSeqNum, bool isOriginal=true, bool warmUp=false, Timestamp messageSendingUtcTimestamp=Timestamp())=0
Logs the given outgoing message.
virtual void storeInboundMessage(const RawMessagePointer &rawMsg, SeqNumber msgSeqNum, bool isOriginal, Timestamp messageReceivingUtcTimestamp=Timestamp())=0
Logs the given inbound message.
virtual Timestamp sessionCreationTime() const =0
virtual SeqNumber previousSeqNum() const =0
virtual SeqNumber outSeqNum() const =0
Messaging::UInt32 SeqNumber
static Enum parse(const std::string &)
@ Undefined
Undefined Session Storage.
@ FileBased
File-based Session Storage.
@ AsyncFileBased
Asynchronous File-Based Session Storage.
@ Pluggable
Pluggable Session Storage.
@ MemoryBased
Memory-based Session Storage.
static const char * toString(SessionStorageType::Enum)
Pointer to the SBE Message.
RawMessagePointer(const char *buffer=nullptr, size_t length=0)