B2BITS FIX Antenna HFT
1.0.16
|
New Incoming Connection. More...
#include <FileMsgStorage.h>
Public Types | |
typedef std::map< typename LogFileT< FileT >::MsgHandle, typename IndexFileT< FileT > ::Data > | RejectedMapT |
typedef std::map< typename LogFileT< FileT >::SeqNum, typename LogFileT< FileT > ::MsgHandle > | ToBeResentCollection |
Public Types inherited from Engine::MsgStorage | |
typedef std::vector < StorableMsg * > | FixMsgs |
typedef std::deque< std::string > | OutgoingMessages |
enum | StorageType { PRIMARY_STORAGE = 0, BACKUP_STORAGE } |
Defines type of the storage. More... | |
Public Types inherited from Engine::Event | |
enum | Type { EVENT, ERROR_EVENT, NOTIFICATION, WARNING, SESSION_ERROR, PARSE_ERROR_IN_SESSION, NEW_INCOMING_CONNECTION, SESSION_NOTIFICATION, SESSION_WAS_CREATED, SESSION_WAS_CONNECTED, SESSION_WAS_CLOSED, SESSION_WAS_ESTABLISHED, SESSION_WAS_RESTORED, SYNCHRONIZATION_COMPLETE, SESSION_WARNING, LINK_ERROR_WAS_DETECTED, LINK_WAS_RESTORED, PERSISTENT_DATA_WERE_FOUND, DEBUG_MESSAGE, SESSION_DEBUG_MESSAGE } |
Event types. More... | |
Public Member Functions | |
FileMsgStorageT (StorageType type, const std::string &baseName, FileT &outFile, FileT &outIndexFile, FileT &inFile, FileT &inIndexFile, Utils::FilePropertiesT< System::FileEx > *configInfo, bool flushStreams, StorageMgr::PersistentSessionInfo *info) | |
Constructor. More... | |
virtual const std::string * | getBaseFilePath () const B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual bool | getBoolConfigInfo (const std::string &aKey, bool *aValue) const B2B_OVERRIDE |
Retrieves configuration information. More... | |
bool | getConfigInfo (const std::string &aKey, std::string *val) const B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
int | getInSeqNum () B2B_OVERRIDE |
virtual bool | getIntConfigInfo (const std::string &aKey, int *aValue) const B2B_OVERRIDE |
Retrieves configuration information. More... | |
int | getMaxSeqNum () B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
int | getMinSeqNum () B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual RejectMsgStorage * | getRejectStorage () B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
const std::string * | getSenderCompID () const |
Returns session's SenderCompID. More... | |
virtual System::u64 | getSessionGlobalID () const |
virtual System::u64 | getSessionInternalState () const |
int | getStoredInSeqNum () const |
Returns current incoming seqNum from config. More... | |
int | getStoredOutSeqNum () const |
Returns current outgoing seqNum from config. More... | |
const std::string * | getTargetCompID () const |
Returns session's TargetCompID. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual Type | getType () const B2B_OVERRIDE |
Returns the event type. More... | |
virtual bool | hasRejectedMessage () B2B_OVERRIDE |
Reimplemented from RejectMsgStorage. More... | |
virtual bool | isPersistentStorage () const B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual bool | isStorageCorrupted () const B2B_OVERRIDE |
Checks if the storage is corrupted. More... | |
LinkErrorWasDetected (const Session *sn, const char *reason) | |
Constructor. More... | |
LinkWasRestored (const Session *sn, const char *message) | |
Constructor. More... | |
int | load (FIXVersion preferredVersion=NA) |
Reimplemented from MsgStorage. More... | |
void | loadInMemoryCache (ToBeResentCollection &toBeResent, int beginSeqNum, int endSeqNum, int currentOutSeqNum) |
virtual bool | logLocal (StorableMsg const *pMsg, const RawMsg &aRawMsg) B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual bool | logLocal (StorableMsg const *pMsg, const char *pRawMsg, int size) B2B_OVERRIDE |
Stores the given outgoing message and then destroys it. More... | |
virtual void | logRemote (StorableMsg const *pMsg, const RawMsg &rawMsg) B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual void | logRemote (StorableMsg const *pMsg, const char *pRawMsg, int size) B2B_OVERRIDE |
Logs the message from the remote FIX engine. More... | |
void | markAsTerminated (bool correctlyTerminated) B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual bool | markRejected (const RawMsg &msg) B2B_OVERRIDE |
Reimplemented from RejectMsgStorage. More... | |
NewIncomingConnection (const std::string &remoreAddress, int remotePort, const std::string &localAddress, int localPort) | |
Constructor. More... | |
ParseErrorInSession (const Session *sn, const Utils::Exception &aReason) | |
Constructor. More... | |
PersistentDataWereFound (const Session *session) | |
Constructor. More... | |
PersistentDataWereFound (const std::string &sender, const std::string &target, SessionRole role) | |
CacheHolderBase * | prepareLocalRetriving (int beginSeqNum, int endSeqNum, int currentOutSeqNum) B2B_OVERRIDE |
Prepare for cache message walk process like a series of retrieveLocal() calls returns an object whose lifetime is bound to the whole series of retrieveLocal() calls when retrieveLocal() calls are complete, the object should be destroyed by the caller. More... | |
bool | retrieveLocal (CacheHolderBase *cacheHolder, ProtocolID protocolID, MsgList *pMsgs, int aBeginSeqNum, int aEndSeqNum=0, FIXVersion preferredVersion=NA) B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual bool | retrieveLocal (int outSeqNum, std::string *msg, int currentOutSeqNum) B2B_OVERRIDE |
Locates sent message (with seqNum=outSeqNum) and returns it into msg. More... | |
virtual void | retrieveRejectedMessages (Utils::Strings *pMessages) B2B_OVERRIDE |
Reimplemented from RejectMsgStorage. More... | |
void | retrieveRemote (ProtocolID protocolID, MsgList *pMessages, const MsgTypes &msgTypes, const FixFieldsList &fieldFilter, int beginSeqNum, int endSeqNum=0, FIXVersion fixVersion=NA) B2B_OVERRIDE |
Fills input list with messages that satisfy selection criteria. More... | |
SessionDebugMessage (const Session *pSn, const std::string &reason) | |
Constructor. More... | |
SessionDebugMessage (const std::string &sender, const std::string &target, const std::string &reason) | |
SessionDebugMessage (const std::string &sender, const std::string &target, SessionRole role, const std::string &reason) | |
SessionWasClosed (const Fast2FixSession *sn, const std::string &reason="") | |
Constructor. More... | |
SessionWasClosed (const std::string &sender, const std::string &target, SessionRole role, bool correctlyTerminated, const std::string &reason="") | |
SessionWasCreated (const Session *sn) | |
Constructor. More... | |
SessionWasEstablished (const Session *sn) | |
Constructor. More... | |
SessionWasEstablished (const std::string &sender, const std::string &target, SessionRole role) | |
SessionWasRestored (const Session *sn) | |
Constructor. More... | |
virtual void | setBoolConfigInfo (const std::string &aKey, bool aValue) B2B_OVERRIDE |
Sets the configuration information. More... | |
void | setConfigInfo (const std::string &aKey, const std::string &val) B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual void | setIntConfigInfo (const std::string &aKey, int aValue) B2B_OVERRIDE |
Sets the configuration information. More... | |
virtual void | setMaxRemoteSeqNum (int msgSeqNum) B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual void | setMinSeqNum (int msgSeqNum) B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual void | setRemoteSeqNum (int msgSeqNum) B2B_OVERRIDE |
Reimplemented from MsgStorage. More... | |
virtual void | setSessionInternalState (const System::u64 internalState) |
virtual void | syncMessageStorage () |
bool | tryMarkRejected (const RawMsg &msg, const ToBeResentCollection &toBeResent) |
virtual bool | unmarkRejected (const RawMsg &msg, const RawMsg &newMsg) B2B_OVERRIDE |
Reimplemented from RejectMsgStorage. More... | |
virtual | ~FileMsgStorageT () |
virtual | ~NewIncomingConnection () |
Destructor. More... | |
virtual | ~SessionDebugMessage () |
Destructor. More... | |
Public Member Functions inherited from Engine::MsgStorage | |
virtual void | clear () |
Clears the storage. More... | |
StorageType | currentConnectionType () const |
Returns type of the storage. More... | |
MsgStorage (StorageType type) | |
Constructor. More... | |
virtual bool | retrieveLocal (CacheHolderBase *cacheHolder, ProtocolID protocolID, std::vector< FIXMessage * > *apMsgs, int aBeginSeqNum, int aEndSeqNum=0, FIXVersion preferredVersion=NA)=0 |
Locates sent messages. More... | |
virtual void | retrieveRemote (ProtocolID protocolID, std::vector< FIXMessage * > *pMessages, const MsgTypes &msgTypes, const std::vector< FixField > &fieldFilter, int beginSeqNum, int endSeqNum=0, FIXVersion fixVersion=NA)=0 |
Fills input list with messages that satisfy selection criteria. More... | |
virtual void | setLastSentSeqNum (int value) |
Updates MsgSeqNum of outgoing messages. More... | |
virtual | ~MsgStorage () |
Destructor. More... | |
Public Member Functions inherited from Engine::RejectMsgStorage | |
virtual | ~RejectMsgStorage () |
Public Member Functions inherited from Engine::DebugMessage | |
DebugMessage (const std::string &msg) | |
Constructor. More... | |
virtual const std::string * | what () const B2B_OVERRIDE |
Describes the event. More... | |
virtual | ~DebugMessage () |
Destructor. More... | |
Public Member Functions inherited from Engine::SessionNotification | |
const std::string * | getSenderCompID () const |
Returns session's SenderCompID. More... | |
const std::string * | getTargetCompID () const |
Returns session's TargetCompID. More... | |
SessionNotification (const Session *pSn) | |
Constructor. More... | |
SessionNotification (const Session *pSn, const std::string &reason) | |
Constructor. More... | |
SessionNotification (const std::string &sender, const std::string &target, SessionRole role, const std::string &reason) | |
virtual | ~SessionNotification () |
Destructor. More... | |
Public Member Functions inherited from Engine::Notification | |
Notification (const std::string &msg) | |
Constructor. More... | |
virtual const std::string * | what () const B2B_OVERRIDE |
Describes the event. More... | |
virtual | ~Notification () |
Destructor. More... | |
Public Member Functions inherited from Engine::SessionWarning | |
const std::string * | getSenderCompID () const |
Returns session's SenderCompID. More... | |
const std::string * | getTargetCompID () const |
Returns session's TargetCompID. More... | |
SessionWarning (const std::string &sender, const std::string &target, const std::string &reason) | |
Constructor. More... | |
SessionWarning (const Session *pSn, const std::string &reason) | |
virtual | ~SessionWarning () |
Destructor. More... | |
Public Member Functions inherited from Engine::Warning | |
Warning (const std::string &msg) | |
Constructor. More... | |
virtual const std::string * | what () const B2B_OVERRIDE |
Describes the event. More... | |
virtual | ~Warning () |
Destructor. More... | |
Public Member Functions inherited from Engine::SessionError | |
const std::string * | getSenderCompID () const |
Returns session's SenderCompID. More... | |
const std::string * | getTargetCompID () const |
Returns session's TargetCompID. More... | |
SessionError (const Session *sn) | |
Constructor. More... | |
SessionError (const std::string &sender, const std::string &target, const std::string &aReason) | |
Constructor. More... | |
SessionError (const Session *sn, const std::string &aReason) | |
virtual const std::string * | what () const B2B_OVERRIDE |
Describes the event. More... | |
virtual | ~SessionError () |
Destructor. More... | |
Public Member Functions inherited from Engine::Error | |
Error (const std::string &msg) | |
Constructor. More... | |
virtual | ~Error () |
Destructor. More... | |
Static Public Member Functions | |
static bool | rebuildIndexS (const std::string &logPath, const std::string &idxPath, const RestoreOptions &options) |
Store messages in range [aBeginSeqNum, aEndSeqNum] into the pMsgs container. More... | |
Protected Member Functions | |
virtual bool | rebuildIndex (const std::string &logPath, const std::string &idxPath, const RestoreOptions &options) B2B_OVERRIDE |
Protected Member Functions inherited from Engine::MsgStorage | |
void | clearFixMsgs (FixMsgs &aMsgs) |
Clears collection (delete all its elements). More... | |
Protected Member Functions inherited from Engine::Event | |
virtual | ~Event () |
Destructor. More... | |
Protected Attributes | |
SessionRole | role_ |
std::string | sender_ |
Sender. More... | |
std::string | target_ |
Target. More... | |
Protected Attributes inherited from Engine::MsgStorage | |
StorageType | currentConnectionType_ |
Protected Attributes inherited from Engine::DebugMessage | |
std::string | m_reason |
Contains std::string that describes the event. More... | |
Protected Attributes inherited from Engine::SessionNotification | |
int | role_ |
Role. More... | |
std::string | sender_ |
Sender. More... | |
std::string | target_ |
Target. More... | |
Protected Attributes inherited from Engine::Notification | |
std::string | m_reason |
Contains std::string that describes the event. More... | |
Protected Attributes inherited from Engine::Warning | |
std::string | m_reason |
Contains std::string that describes the event. More... | |
Protected Attributes inherited from Engine::Error | |
std::string | m_reason |
Contains std::string that describes the event. More... | |
Friends | |
class | ::TestApplication |
class | TestSeqNo |
Additional Inherited Members | |
Static Public Attributes inherited from Engine::MsgStorage | |
static const System::u64 | SessionInternalStateNA = 0 |
New Incoming Connection.
FileT message storage.
Represents debug message related to Session.
Session was established.
Session was restored from Persistent Message Storage.
A telecommunication link error was detected.
A telecommunication link was restored.
Session was closed.
Session was created.
Parse error was detected.
This event is fired when the persistent information about session is found.
typedef std::map<typename LogFileT<FileT>::MsgHandle, typename IndexFileT<FileT>::Data> Engine::B2B_SEALED< FileT >::RejectedMapT |
typedef std::map<typename LogFileT<FileT>::SeqNum, typename LogFileT<FileT>::MsgHandle> Engine::B2B_SEALED< FileT >::ToBeResentCollection |
|
inlinevirtual |
Destructor.
|
inlinevirtual |
Destructor.
|
virtual |
Engine::B2B_SEALED< FileT >::FileMsgStorageT | ( | StorageType | type, |
const std::string & | baseName, | ||
FileT & | outFile, | ||
FileT & | outIndexFile, | ||
FileT & | inFile, | ||
FileT & | inIndexFile, | ||
Utils::FilePropertiesT< System::FileEx > * | configInfo, | ||
bool | flushStreams, | ||
StorageMgr::PersistentSessionInfo * | info | ||
) |
Constructor.
baseName | Base file name. |
outFile | - file to store outgoing messages. |
outIndexFile | - index file. |
inFile | - file to store incoming messages. |
inIndexFile | - index file. |
flushStreams | - if true then all input/output will be flushed after each operation. |
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Retrieves configuration information.
aKey | - parameter key |
aValue | - parameter result value |
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from Engine::MsgStorage.
|
virtual |
Retrieves configuration information.
aKey | - parameter key |
aValue | - parameter result value |
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Reimplemented from Engine::MsgStorage.
|
inline |
Returns session's SenderCompID.
|
virtual |
Reimplemented from Engine::MsgStorage.
|
virtual |
Reimplemented from Engine::MsgStorage.
int Engine::B2B_SEALED< FileT >::getStoredInSeqNum | ( | ) | const |
Returns current incoming seqNum from config.
int Engine::B2B_SEALED< FileT >::getStoredOutSeqNum | ( | ) | const |
Returns current outgoing seqNum from config.
|
inline |
Returns session's TargetCompID.
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
inlinevirtual |
|
virtual |
Reimplemented from RejectMsgStorage.
Implements Engine::RejectMsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Checks if the storage is corrupted.
Implements Engine::MsgStorage.
Engine::B2B_SEALED< FileT >::LinkErrorWasDetected | ( | const Session * | sn, |
const char * | reason | ||
) |
Constructor.
sn | Instance of Session assigned with event |
reason | Message that describes event. Can be NULL; |
Engine::B2B_SEALED< FileT >::LinkWasRestored | ( | const Session * | sn, |
const char * | message | ||
) |
Constructor.
sn | Session. |
message | std::string that describes this event. |
int Engine::B2B_SEALED< FileT >::load | ( | FIXVersion | preferredVersion = NA | ) |
Reimplemented from MsgStorage.
Reimplemented from MsgStorage. Reads the messages from the message log.
void Engine::B2B_SEALED< FileT >::loadInMemoryCache | ( | ToBeResentCollection & | toBeResent, |
int | beginSeqNum, | ||
int | endSeqNum, | ||
int | currentOutSeqNum | ||
) |
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Stores the given outgoing message and then destroys it.
apMsg | - storage message |
nSeqNum | - message number |
pRawMsg | - message buffer pointer |
size | - message buffer size |
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Logs the message from the remote FIX engine.
msgSeqNum | - message number |
pRawMsg | - message buffer pointer |
size | - message buffer size |
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from RejectMsgStorage.
Implements Engine::RejectMsgStorage.
Engine::B2B_SEALED< FileT >::NewIncomingConnection | ( | const std::string & | remoreAddress, |
int | remotePort, | ||
const std::string & | localAddress, | ||
int | localPort | ||
) |
Constructor.
remoreAddress | Remote host address. |
remotePort | Remote port. |
localAddress | Local host address. |
localPort | Local port. |
Engine::B2B_SEALED< FileT >::ParseErrorInSession | ( | const Session * | sn, |
const Utils::Exception & | aReason | ||
) |
Constructor.
Engine::B2B_SEALED< FileT >::PersistentDataWereFound | ( | const Session * | session | ) |
Constructor.
session | Instance of Session assigned event with. |
Engine::B2B_SEALED< FileT >::PersistentDataWereFound | ( | const std::string & | sender, |
const std::string & | target, | ||
SessionRole | role | ||
) |
|
virtual |
Prepare for cache message walk process like a series of retrieveLocal() calls returns an object whose lifetime is bound to the whole series of retrieveLocal() calls when retrieveLocal() calls are complete, the object should be destroyed by the caller.
Returned pointer can have NULL value. To control the lifetime, should be used in conjunction with std::auto_ptr<> The implementaion would typically load the messages from an external storage to memory to prepare for a series of retrieveLocal() calls
Implements Engine::MsgStorage.
|
protectedvirtual |
Implements Engine::MsgStorage.
|
static |
Store messages in range [aBeginSeqNum, aEndSeqNum] into the pMsgs container.
bool Engine::B2B_SEALED< FileT >::retrieveLocal | ( | CacheHolderBase * | cacheHolder, |
ProtocolID | protocolID, | ||
MsgList * | pMsgs, | ||
int | aBeginSeqNum, | ||
int | aEndSeqNum = 0 , |
||
FIXVersion | preferredVersion = NA |
||
) |
Reimplemented from MsgStorage.
|
virtual |
Locates sent message (with seqNum=outSeqNum) and returns it into msg.
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from RejectMsgStorage.
Implements Engine::RejectMsgStorage.
void Engine::B2B_SEALED< FileT >::retrieveRemote | ( | ProtocolID | protocolID, |
MsgList * | pMessages, | ||
const MsgTypes & | msgTypes, | ||
const FixFieldsList & | fieldFilter, | ||
int | beginSeqNum, | ||
int | endSeqNum = 0 , |
||
FIXVersion | fixVersion = NA |
||
) |
Fills input list with messages that satisfy selection criteria.
Engine::B2B_SEALED< FileT >::SessionDebugMessage | ( | const Session * | pSn, |
const std::string & | reason | ||
) |
Constructor.
Engine::B2B_SEALED< FileT >::SessionDebugMessage | ( | const std::string & | sender, |
const std::string & | target, | ||
const std::string & | reason | ||
) |
Engine::B2B_SEALED< FileT >::SessionDebugMessage | ( | const std::string & | sender, |
const std::string & | target, | ||
SessionRole | role, | ||
const std::string & | reason | ||
) |
Engine::B2B_SEALED< FileT >::SessionWasClosed | ( | const Fast2FixSession * | sn, |
const std::string & | reason = "" |
||
) |
Constructor.
sn | Session. |
reason | Reason of session closing. |
Engine::B2B_SEALED< FileT >::SessionWasClosed | ( | const std::string & | sender, |
const std::string & | target, | ||
SessionRole | role, | ||
bool | correctlyTerminated, | ||
const std::string & | reason = "" |
||
) |
Engine::B2B_SEALED< FileT >::SessionWasCreated | ( | const Session * | sn | ) |
Constructor.
Engine::B2B_SEALED< FileT >::SessionWasEstablished | ( | const Session * | sn | ) |
Constructor.
sn | Instance of Session assigned with event |
Engine::B2B_SEALED< FileT >::SessionWasEstablished | ( | const std::string & | sender, |
const std::string & | target, | ||
SessionRole | role | ||
) |
Engine::B2B_SEALED< FileT >::SessionWasRestored | ( | const Session * | sn | ) |
Constructor.
sn | Instance of Session assigned with event |
|
virtual |
Sets the configuration information.
aKey | - parameter key |
aValue | - parameter value |
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Sets the configuration information.
aKey | - parameter key |
aValue | - parameter value |
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from MsgStorage.
Implements Engine::MsgStorage.
|
virtual |
Reimplemented from Engine::MsgStorage.
|
virtual |
Implements Engine::MsgStorage.
bool Engine::B2B_SEALED< FileT >::tryMarkRejected | ( | const RawMsg & | msg, |
const ToBeResentCollection & | toBeResent | ||
) |
|
virtual |
Reimplemented from RejectMsgStorage.
Implements Engine::RejectMsgStorage.
|
friend |
|
friend |
|
protected |
|
protected |
Sender.
|
protected |
Target.