MessageStore.h
Go to the documentation of this file.
/* -*- C++ -*- */
/****************************************************************************
** Copyright (c) 2001-2014
**
** This file is part of the QuickFIX FIX Engine
**
** This file may be distributed under the terms of the quickfixengine.org
** license as defined by quickfixengine.org and appearing in the file
** LICENSE included in the packaging of this file.
**
** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
**
** See http://www.quickfixengine.org/LICENSE for licensing information.
**
** Contact ask@quickfixengine.org if any conditions of this licensing are
** not clear to you.
**
****************************************************************************/
#ifndef FIX_MESSAGESTORE_H
#define FIX_MESSAGESTORE_H
#ifdef _MSC_VER
#pragma warning( disable : 4503 4355 4786 4290 )
#endif
#include "Message.h"
#include <map>
#include <vector>
#include <string>
namespace FIX
{
class MessageStore;
class MessageStoreFactory
{
public:
virtual ~MessageStoreFactory() {}
virtual MessageStore* create( const SessionID& ) = 0;
virtual void destroy( MessageStore* ) = 0;
};
class MemoryStoreFactory : public MessageStoreFactory
{
public:
MessageStore* create( const SessionID& );
void destroy( MessageStore* );
};
class MessageStore
{
public:
virtual ~MessageStore() {}
virtual bool set( int, const std::string& )
throw ( IOException ) = 0;
virtual void get( int, int, std::vector < std::string > & ) const
throw ( IOException ) = 0;
virtual int getNextSenderMsgSeqNum() const throw ( IOException ) = 0;
virtual int getNextTargetMsgSeqNum() const throw ( IOException ) = 0;
virtual void setNextSenderMsgSeqNum( int ) throw ( IOException ) = 0;
virtual void setNextTargetMsgSeqNum( int ) throw ( IOException ) = 0;
virtual void incrNextSenderMsgSeqNum() throw ( IOException ) = 0;
virtual void incrNextTargetMsgSeqNum() throw ( IOException ) = 0;
virtual UtcTimeStamp getCreationTime() const throw ( IOException ) = 0;
virtual void reset() throw ( IOException ) = 0;
virtual void refresh() throw ( IOException ) = 0;
};
class MemoryStore : public MessageStore
{
public:
MemoryStore() : m_nextSenderMsgSeqNum( 1 ), m_nextTargetMsgSeqNum( 1 ) {}
bool set( int, const std::string& ) throw ( IOException );
void get( int, int, std::vector < std::string > & ) const throw ( IOException );
int getNextSenderMsgSeqNum() const throw ( IOException )
{ return m_nextSenderMsgSeqNum; }
int getNextTargetMsgSeqNum() const throw ( IOException )
{ return m_nextTargetMsgSeqNum; }
void setNextSenderMsgSeqNum( int value ) throw ( IOException )
{ m_nextSenderMsgSeqNum = value; }
void setNextTargetMsgSeqNum( int value ) throw ( IOException )
{ m_nextTargetMsgSeqNum = value; }
void incrNextSenderMsgSeqNum() throw ( IOException )
{ ++m_nextSenderMsgSeqNum; }
void incrNextTargetMsgSeqNum() throw ( IOException )
{ ++m_nextTargetMsgSeqNum; }
void setCreationTime( const UtcTimeStamp& creationTime ) throw ( IOException )
{ m_creationTime = creationTime; }
UtcTimeStamp getCreationTime() const throw ( IOException )
{ return m_creationTime; }
void reset() throw ( IOException )
{
m_nextSenderMsgSeqNum = 1; m_nextTargetMsgSeqNum = 1;
m_messages.clear(); m_creationTime.setCurrent();
}
void refresh() throw ( IOException ) {}
private:
typedef std::map < int, std::string > Messages;
Messages m_messages;
int m_nextSenderMsgSeqNum;
int m_nextTargetMsgSeqNum;
UtcTimeStamp m_creationTime;
};
class MessageStoreFactoryExceptionWrapper
{
private:
MessageStoreFactory* m_pFactory;
public:
MessageStoreFactoryExceptionWrapper( MessageStoreFactory* pFactory )
: m_pFactory( pFactory ) {}
MessageStore* create( const SessionID&, bool&, ConfigError& );
void destroy( MessageStore* );
};
class MessageStoreExceptionWrapper
{
private:
MessageStore* m_pStore;
public:
MessageStoreExceptionWrapper( MessageStore* pStore ) : m_pStore( pStore ) {}
~MessageStoreExceptionWrapper() { delete m_pStore; }
bool set( int, const std::string&, bool&, IOException& );
void get( int, int, std::vector < std::string > &, bool&, IOException& ) const;
int getNextSenderMsgSeqNum( bool&, IOException& ) const;
int getNextTargetMsgSeqNum( bool&, IOException& ) const;
void setNextSenderMsgSeqNum( int, bool&, IOException& );
void setNextTargetMsgSeqNum( int, bool&, IOException& );
void incrNextSenderMsgSeqNum( bool&, IOException& );
void incrNextTargetMsgSeqNum( bool&, IOException& );
UtcTimeStamp getCreationTime( bool&, IOException& );
void reset( bool&, IOException& );
void refresh( bool&, IOException& );
};
}
#endif //FIX_MESSAGESTORE_H
FIX::MemoryStore::Messages
std::map< int, std::string > Messages
Definition: MessageStore.h:147
FIX::MessageStoreFactory::create
virtual MessageStore * create(const SessionID &)=0
FIX::MessageStoreFactory
This interface must be implemented to create a MessageStore.
Definition: MessageStore.h:58
FIX::UtcTimeStamp
Date and Time represented in UTC.
Definition: FieldTypes.h:599
FIX::MessageStoreFactory::destroy
virtual void destroy(MessageStore *)=0
FIX::MessageStore::getCreationTime
virtual UtcTimeStamp getCreationTime() const =0
FIX::ConfigError
Application is not configured correctly
Definition: Exceptions.h:104
FIX::SessionID
Unique session id consists of BeginString, SenderCompID and TargetCompID.
Definition: SessionID.h:47
FIX::MessageStore::incrNextSenderMsgSeqNum
virtual void incrNextSenderMsgSeqNum()=0
FIX::IOException
IO Error.
Definition: Exceptions.h:255
FIX::MessageStore::incrNextTargetMsgSeqNum
virtual void incrNextTargetMsgSeqNum()=0
FIX::MessageStore::~MessageStore
virtual ~MessageStore()
Definition: MessageStore.h:86
FIX::MessageStore::reset
virtual void reset()=0
FIX::MessageStore::setNextTargetMsgSeqNum
virtual void setNextTargetMsgSeqNum(int)=0
FIX::MessageStore::refresh
virtual void refresh()=0
FIX::MessageStore
This interface must be implemented to store and retrieve messages and sequence numbers.
Definition: MessageStore.h:83
FIX::MessageStore::set
virtual bool set(int, const std::string &)=0
FIX::MessageStoreExceptionWrapper
Definition: MessageStore.h:167
FIX::MessageStoreFactoryExceptionWrapper
Definition: MessageStore.h:155
FIX
Definition: Acceptor.cpp:34
FIX::MessageStoreFactory::~MessageStoreFactory
virtual ~MessageStoreFactory()
Definition: MessageStore.h:61
FIX::MemoryStore
Memory based implementation of MessageStore.
Definition: MessageStore.h:113
FIX::MessageStore::get
virtual void get(int, int, std::vector< std::string > &) const =0
FIX::MemoryStoreFactory::destroy
void destroy(MessageStore *)
Definition: MessageStore.cpp:52
FIX::MessageStore::getNextSenderMsgSeqNum
virtual int getNextSenderMsgSeqNum() const =0
FIX::MemoryStoreFactory::create
MessageStore * create(const SessionID &)
Definition: MessageStore.cpp:47
FIX::MessageStore::getNextTargetMsgSeqNum
virtual int getNextTargetMsgSeqNum() const =0
Message.h
FIX::MessageStore::setNextSenderMsgSeqNum
virtual void setNextSenderMsgSeqNum(int)=0