FIX Engine interface. More...

#include <B2BITS_FixEngine.h>

Classes
struct	InitParameters
	FixEngine::init parameters. More...

Public Member Functions
FixEngineImpl *	_impl ()

void	backupLogFile (const std::string &backupFilePath)
	Backups engine's log file under the given name and opens a new one.

bool	cancelScheduledSessionRestart (const SessionId &sessionId)
	Cancels a scheduled by the SessionsManager::onSessionTerminated() callback restart of a session with given SessionId.

Session *	createAcceptor (int port, Application pApp, const std::string &senderCompID, const std::string &targetCompID, ParserID scpID, const SessionExtraParameters pParam=NULL)
	Creates FIX acceptor.

Bats::Application *	createBatsApplication (const Bats::ApplicationOptions &options, Bats::ApplicationListener *listener)
	Creates an instance of the Bats Market Data Adapter.

Bovespa::BovespaApplication *	createBovespaApplication (Bovespa::BovespaApplicationParams const &params, Bovespa::BovespaApplicationListener *appListener=NULL)
	Creates instance of the Bovespa FIX/FAST adapter.

Bovespa::BovespaApplication *	createBovespaApplication (Bovespa::BovespaApplicationParams const &params, MarketData::DataReaderAbstract dataReader, Bovespa::BovespaApplicationListener appListener=NULL)

b2bits::CBOE::CMi2::Initiator *	createCboeCmi2Initiator (b2bits::CBOE::CMi2::SessionParameters const &params)
	Creates instance of the CBOE CMi2 Initiator.

Cboe::Csm::CboeCsmApplication *	createCboeCsmApplication (Cboe::Csm::CboeCsmApplicationParams const &params, Cboe::Csm::CboeCsmApplicationListener *appListener=NULL)
	Creates instance of the CBOE CSM adapter.

Cboe::Csm::CboeCsmApplication *	createCboeCsmApplication (Cboe::Csm::CboeCsmApplicationParams const &params, MarketData::DataReaderAbstract dataReader, Cboe::Csm::CboeCsmApplicationListener appListener=NULL)

Cboe::MarketDepth::CboeMarketDepthApplication *	createCboeMarketDepthApplication (Cboe::MarketDepth::CboeMarketDepthApplicationParams const &params, Cboe::MarketDepth::CboeMarketDepthApplicationListener *appListener=NULL)
	Creates instance of the CBOE Market Depth adapter.

Cme::Mdp::MarketDataService *	createCmeMdpMarketDataService (const std::string &name, const Cme::Mdp::MarketDataServiceOptions &options)
	Creates an instance of the CME MDP3 Market Data Adapter.

Cqg::MDApplication *	createCqgMDApplication (Cqg::MDApplicationListener listener, Cqg::MDApplicationParams const &params, MarketData::DataReaderAbstract dataReader=NULL)
	Creates instance of the CQG FIX/FAST Market Data adapter It is user's responsibility to call Cqg::MDApplication::release method.

FastCoder *	createFastCoder (std::string const &template_fn, Engine::FIXVersion appProtocolVersion, Engine::FIXVersion scpProtocolVersion)
	Creates FastCoder It is user's responsibility to destroy FastCoder instance.

FastCoder *	createFastCoder (std::string const &template_fn, Engine::FIXVersion protocolVersion)
	Creates FastCoder It is user's responsibility to destroy FastCoder instance.

FastDecoder *	createFastDecoder (std::string const &template_fn, Engine::FIXVersion appProtocolVersion, Engine::FIXVersion scpProtocolVersion)
	Creates FastDecoder It is user's responsibility to destroy FastDecoder instance.

FastDecoder *	createFastDecoder (std::string const &template_fn, Engine::FIXVersion protocolVersion)
	Creates FastDecoder It is user's responsibility to destroy FastDecoder instance.

Session *	createFastSession (std::string const &templateFn, Application pApp, const SessionId &sessionId, FIXVersion appVer, const FastSessionExtraParameters pParam=NULL)
	Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

Session *	createFastSession (std::string const &templateFn, Application pApp, const SessionId &sessionId, FIXVersion appVer, FIXVersion scpVer, const FastSessionExtraParameters pParam=NULL)
	Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

Session *	createFastSession (std::string const &templateFn, Application pApp, const std::string &senderCompID, const std::string &targetCompID, FIXVersion appVer, const FastSessionExtraParameters pParam=NULL)
	Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

Session *	createFastSession (std::string const &templateFn, Application pApp, const std::string &senderCompID, const std::string &targetCompID, FIXVersion appVer, const SessionExtraParameters pParam, const MessageStorageType storageType=default_storageType)
	Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

Session *	createFastSession (std::string const &templateFn, Application pApp, const std::string &senderCompID, const std::string &targetCompID, FIXVersion appVer, FIXVersion scpVer, const FastSessionExtraParameters pParam=NULL)
	Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

ParserID	createFixParser (DictionaryID const &scpProtocolName, DictionaryID const &appProtocol)
	Creates FIXT11 protocol using loaded protocol definition files.

ParserID	createFixParser (DictionaryID const &scpProtocolName, FixVersionToProtocolName const *appProtocols)

ParserID	createFixParser (DictionaryID const &scpProtocolName, nullptr_t appProtocols)

ParserID	createFixParser (DictionaryID const &scpProtocolName, ProtocolNames const *appProtocols=NULL)
	Creates protocol using loaded protocol definition files.

ParserID	createFixParser (ParserName const &parserName, DictionaryID const &scpProtocolName, DictionaryID appProtocol)
	Creates FIXT11 protocol using loaded protocol definition files.

ParserID	createFixParser (ParserName const &parserName, DictionaryID const &scpProtocolName, FixVersionToProtocolName const *appProtocols)

ParserID	createFixParser (ParserName const &parserName, DictionaryID const &scpProtocolName, nullptr_t appProtocols)

ParserID	createFixParser (ParserName const &parserName, DictionaryID const &scpProtocolName, ProtocolNames const *appProtocols)
	Creates FIXT11 protocol using loaded protocol definition files.

Forts::FortsApplication *	createFortsApplication (Forts::FortsApplicationParams const &params, Forts::FortsApplicationListener *appListener=NULL)
	Creates instance of the MOEX RTS FORTS FIX/FAST adapter It is user's responsibility to call Forts::MDApplication::release method.

Forts::FortsApplication *	createFortsApplication (Forts::FortsApplicationParams const &params, MarketData::DataReaderAbstract dataReader, Forts::FortsApplicationListener appListener=NULL)
	Creates instance of the MOEX RTS FORTS FIX/FAST adapter It is user's responsibility to call Forts::MDApplication::release method.

Globex2::GlobexApplication *	createGlobexApplication (Globex2::GlobexApplicationParams const &params, Globex2::GlobexApplicationListener *appListener=NULL)
	Creates instance of the CME Globex FIX/FAST adapter v.2 It is user's responsibility to call Globex::MDApplication::release method.

Globex2::GlobexApplication *	createGlobexApplication (Globex2::GlobexApplicationParams const &params, MarketData::DataReaderAbstract dataReader, Globex2::GlobexApplicationListener appListener=NULL)
	Creates instance of the CME Globex FIX/FAST adapter v.2 It is user's responsibility to call Globex::MDApplication::release method.

GlobexSbe::GlobexApplication *	createGlobexSbeApplication (GlobexSbe::GlobexApplicationParams const &params, GlobexSbe::GlobexApplicationListener *appListener=NULL)

GlobexSbe::GlobexApplication *	createGlobexSbeApplication (GlobexSbe::GlobexApplicationParams const &params, MarketData::DataReaderAbstract dataReader, GlobexSbe::GlobexApplicationListener appListener=NULL)

Session *	createInitiator (Application pApp, const std::string &senderCompID, const std::string &targetCompID, ParserID scpID, const SessionExtraParameters pParam=NULL)
	Creates FIX initiator.

Cboe::MarketDepth::CboeMarketDepthApplication *	createMarketDepthApplication (Cboe::MarketDepth::CboeMarketDepthApplicationParams const &params, MarketData::DataReaderAbstract dataReader, Cboe::MarketDepth::CboeMarketDepthApplicationListener appListener=NULL)

Globex::MDApplication *	createMDApplication (Globex::MDApplicationParams const &params, Globex::DataReaderAbstract dataReader, Globex::MDApplicationListener appListener=NULL)
	Creates instance of the CME Globex FIX/FAST adapter It is user's responsibility to call Globex::MDApplication::release method.

Globex::MDApplication *	createMDApplication (Globex::MDApplicationParams const &params, Globex::MDApplicationListener *appListener=NULL)
	Creates instance of the CME Globex FIX/FAST adapter It is user's responsibility to call Globex::MDApplication::release method.

Mit::Application *	createMitApplication (Mit::ConnectionManager *connectionManager, const std::string &configurationFilename)
	Creates an instance of the MilleniumIT Market Data Adapter.

Mit::Application *	createMitApplication (Mit::ConnectionManager *connectionManager, const std::string &name, const Mit::ApplicationOptions &applicationOptions)
	Creates an instance of the MilleniumIT Market Data Adapter.

ParserID	createProtocol (std::string const &name, FIXVersion baseVer, std::string const &additionalXml)
	Register new custom FIX Protocol and returns its identifier.

Session *	createSession (Application pApp, const SessionId &sessionId, FIXVersion appVer=NA, const SessionExtraParameters pParam=NULL, const MessageStorageType storageType=default_storageType, UnderlyingProtocol underlyingProtocolType=FIX_TCP)
	Creates a new FIX Session.

Session *	createSession (Application pApp, const SessionId &sessionId, ParserID scpID, const SessionExtraParameters pParam=NULL, const MessageStorageType storageType=default_storageType, ProtocolIndex defaultAppProtocol=NA)
	Creates a new FIX Session.

Session *	createSession (Application pApp, const SessionId &sessionId, ParserName const &parserName, const SessionExtraParameters pParam=NULL, const MessageStorageType storageType=default_storageType, FIXVersion defaultAppProtocol=NA)
	Creates a new FIX Session.

Session *	createSession (Application pApp, const std::string &senderCompID, const std::string &targetCompID, FIXVersion appVer=NA, const SessionExtraParameters pParam=NULL, const MessageStorageType storageType=default_storageType, UnderlyingProtocol underlyingProtocolType=FIX_TCP)
	Creates a new FIX Session.

Session *	createSession (Application pApp, const std::string &senderCompID, const std::string &targetCompID, ParserID scpID, const SessionExtraParameters pParam=NULL, const MessageStorageType storageType=default_storageType, ProtocolIndex defaultAppProtocol=NA)
	Creates a new FIX Session.

Session *	createSession (Application pApp, const std::string &senderCompID, const std::string &targetCompID, ParserName const &parserName, const SessionExtraParameters pParam=NULL, const MessageStorageType storageType=default_storageType, FIXVersion defaultAppProtocol=NA)
	Creates a new FIX Session.

Spectra::SpectraApplication *	createSpectraApplication (Spectra::SpectraApplicationParams const &params, MarketData::DataReaderAbstract dataReader, Spectra::SpectraApplicationListener appListener=NULL)
	Creates instance of the MOEX RTS SPECTRA FIX/FAST adapter It is user's responsibility to call Spectra::MDApplication::release method.

Spectra::SpectraApplication *	createSpectraApplication (Spectra::SpectraApplicationParams const &params, Spectra::SpectraApplicationListener *appListener=NULL)
	Creates instance of the MOEX RTS SPECTRA FIX/FAST adapter It is user's responsibility to call Spectra::MDApplication::release method.

ParserID	findParser (const ParserDescription &parserDescription) const
	Finds registered parser id by partially filled parser desription.

AdminApplication *	getAdminApplication ()
	Returns administrative application.

DictionaryID const *	getAppProtocolName (ParserID parserID, ProtocolIndex protocolIndex) const
	Returns application protocol name for given parser and protocol.

FIXVersion	getBaseProtocol (ParserID parserID) const
	Returns base FIX protocol version.

FixDictionary2::Dictionary const *	getDictionary () const
	Returns reference to protocol dictionary.

std::string	getLicenseExpirationDate ()
	Returns license expiration date in the 'YYYY-MM-DD' format.

int	getListenPort () const
	Returns engine listen port number.

ListenPorts	getListenPorts () const
	Returns engine listen ports.

ParserDescription	getParserDescription (Engine::ParserID parserID) const
	Returns parser description for given parser id.

ParserID	getParserID (ParserName const &name) const
	Returns unique parser ID.

ParserName const &	getParserName (ParserID parserID) const
	Returns unique parser name.

ParserIDToParserNamePtr	getParsers () const
	Returns set of registered parsers include custom parsers.

const FAProperties *	getProperties () const
	Returns settings.

FixDictionary2::ProtocolT::CPtr	getProtocol (std::string const &protocolName) const
	Returns registered protocol by protocol name.

FIXVersion	getProtocolBaseVersion (std::string const &protocolName) const
	Returns base version of registered protocol by protocol name.

ParserID	getProtocolID (const std::string &name) const
	Returns unique parser ID.

Engine::AsciiString	getProtocolName (ParserID parserID) const
	Returns unique parser name.

ProtocolIndexToProtocolName const *	getProtocols (ParserID parserID) const
	Returns set of application level protocols for given parser.

System::SchedulerPtr	getScheduler () const
	Returns engine's scheduler used to run cobfigured schedules.

DictionaryID const *	getScpProtocolName (ParserID parserID) const
	Returns transport protocol name for given parser.

Session *	getSession (const SessionId &sessionId)
	Searches for a session by sessionId consisting of senderCompID, targetCompID and session qualifier.

Session *	getSession (const std::string &senderCompID, const std::string &targetCompID)
	Searches for a session with given senderCompID/targetCompID with empty session qualifier.

Engine::SessionsManager *	getSessionsManager ()
	Returns the current SessionsManager.

void	getStatistics (Statistics *apS)
	Returns the statistical information.

MessageStorageType	getUnregisteredAcceptorSessionStorageType () const
	Returns the default unregistered session's storage type.

FixDictionary2::Dictionary::DictionariesInfo	loadProtocolFile (std::string const &fileName)
	Loads protocol definition/customization file.

void	registerAdminApplication (AdminApplication *app)
	Register administrative application.

void	registerEventListener (Engine::EventListener *apListener)
	Registers the given EventListener with FixEngine.

void	registerSessionsManager (SessionsManager *apManager)
	Registers SessionsManager with the engine.

void	setUnregisteredAcceptorSessionStorageType (const MessageStorageType type)
	Sets the default unregistered session's storage type.

void	startListeningIncomingConnections ()
	Makes the engine listen to incoming connections.

void	stop ()
	Stops the engine's worker threads.

void	stopListeningIncomingConnections ()
	Pauses the engine listen to incoming connections.

bool	unregisterEventListener (Engine::EventListener *apListener)
	Unregisters the given EventListener.

Static Public Member Functions
static void	clearAdditionalFields ()
	Destroys the additional fields.

static void	destroy ()
	Destroys the instance of this class.

static const EngineProperties	getEnginePropertiesDefaults ()
	Retrieves properties defaults.

static std::string	getEngineVersion ()
	Returns version of the FixEngine.

static FixEngine *	init (const EngineProperties &engineProperties, const std::string &licenseKey="", bool initUtilsLogger=true, const SSLCustomContextProperties &customSSLContextProperties=SSLCustomContextProperties())
	Initializes the Engine.

static FixEngine *	init (const std::string &propertiesFileName="", int listenPort=-1, const std::string &engineRoot="", const std::string &additionalFields="", const std::string &licenseKey="", bool initUtilsLogger=true, const SSLCustomContextProperties &customSSLContextProperties=SSLCustomContextProperties())
	Initializes the Engine.

static FixEngine *	init (InitParameters const &params)
	Initializes the Engine.

static bool	initialized ()
	Returns true if FixEngine was initialized; false otherwise.

static void	reset_revision (const char *r)
	Using by FA to log real revision number, to avoid static relink.

static void	setAdditionalFields (const std::string &propertiesFileName="", const std::string &engineRoot="", const std::string &additionalFields="")
	Initializes the additional fields.

static FixEngine *	singleton ()
	Returns an instance of this class.

Detailed Description

FIX Engine interface.

Member Function Documentation

◆ _impl()

FixEngineImpl * Engine::FixEngine::_impl ( )

◆ backupLogFile()

void Engine::FixEngine::backupLogFile ( const std::string & backupFilePath )

Backups engine's log file under the given name and opens a new one.

Parameters

backupFilePath the current engine's log will be moved to this path.

◆ cancelScheduledSessionRestart()

bool Engine::FixEngine::cancelScheduledSessionRestart ( const SessionId & sessionId )

Cancels a scheduled by the SessionsManager::onSessionTerminated() callback restart of a session with given SessionId.

Parameters

sessionId SessionID of the session

Returns: true if there was a restart scheduled for the session and it was successfully canceled and false otherwise.

◆ clearAdditionalFields()

static void Engine::FixEngine::clearAdditionalFields ( )

static

Destroys the additional fields.

Note: Do not use it with destroy() method.

◆ createAcceptor()

Session * Engine::FixEngine::createAcceptor	(	int	port,
		Application *	pApp,
		const std::string &	senderCompID,
		const std::string &	targetCompID,
		ParserID	scpID,
		const SessionExtraParameters *	pParam = NULL )

Creates FIX acceptor.

This session is experimental.

Parameters

port	Listen TCP port
pApp	Session event listener
senderCompID	SenderCompID of the session.
targetCompID	TargetCompID of the session.
scpID	FIX session control protocol identifier.
pParam	an option session parameters, can be NULL.

Warning: This session is experimental.

◆ createBatsApplication()

Bats::Application * Engine::FixEngine::createBatsApplication	(	const Bats::ApplicationOptions &	options,
		Bats::ApplicationListener *	listener )

Creates an instance of the Bats Market Data Adapter.

The application should be destroyed with Application::release().

◆ createBovespaApplication() [1/2]

Bovespa::BovespaApplication * Engine::FixEngine::createBovespaApplication	(	Bovespa::BovespaApplicationParams const &	params,
		Bovespa::BovespaApplicationListener *	appListener = NULL )

Creates instance of the Bovespa FIX/FAST adapter.

◆ createBovespaApplication() [2/2]

Bovespa::BovespaApplication * Engine::FixEngine::createBovespaApplication	(	Bovespa::BovespaApplicationParams const &	params,
		MarketData::DataReaderAbstract *	dataReader,
		Bovespa::BovespaApplicationListener *	appListener = NULL )

Note: For testing purposes only.

◆ createCboeCmi2Initiator()

b2bits::CBOE::CMi2::Initiator * Engine::FixEngine::createCboeCmi2Initiator ( b2bits::CBOE::CMi2::SessionParameters const & params )

Creates instance of the CBOE CMi2 Initiator.

◆ createCboeCsmApplication() [1/2]

Cboe::Csm::CboeCsmApplication * Engine::FixEngine::createCboeCsmApplication	(	Cboe::Csm::CboeCsmApplicationParams const &	params,
		Cboe::Csm::CboeCsmApplicationListener *	appListener = NULL )

Creates instance of the CBOE CSM adapter.

◆ createCboeCsmApplication() [2/2]

Cboe::Csm::CboeCsmApplication * Engine::FixEngine::createCboeCsmApplication	(	Cboe::Csm::CboeCsmApplicationParams const &	params,
		MarketData::DataReaderAbstract *	dataReader,
		Cboe::Csm::CboeCsmApplicationListener *	appListener = NULL )

Note: For testing purposes only.

◆ createCboeMarketDepthApplication()

Cboe::MarketDepth::CboeMarketDepthApplication * Engine::FixEngine::createCboeMarketDepthApplication	(	Cboe::MarketDepth::CboeMarketDepthApplicationParams const &	params,
		Cboe::MarketDepth::CboeMarketDepthApplicationListener *	appListener = NULL )

Creates instance of the CBOE Market Depth adapter.

◆ createCmeMdpMarketDataService()

Cme::Mdp::MarketDataService * Engine::FixEngine::createCmeMdpMarketDataService	(	const std::string &	name,
		const Cme::Mdp::MarketDataServiceOptions &	options )

Creates an instance of the CME MDP3 Market Data Adapter.

The adaper should be destroyed with MarketDataService::destroy().

◆ createCqgMDApplication()

Cqg::MDApplication * Engine::FixEngine::createCqgMDApplication	(	Cqg::MDApplicationListener *	listener,
		Cqg::MDApplicationParams const &	params,
		MarketData::DataReaderAbstract *	dataReader = NULL )

Creates instance of the CQG FIX/FAST Market Data adapter It is user's responsibility to call Cqg::MDApplication::release method.

◆ createFastCoder() [1/2]

FastCoder * Engine::FixEngine::createFastCoder	(	std::string const &	template_fn,
		Engine::FIXVersion	appProtocolVersion,
		Engine::FIXVersion	scpProtocolVersion )

Creates FastCoder It is user's responsibility to destroy FastCoder instance.

◆ createFastCoder() [2/2]

FastCoder * Engine::FixEngine::createFastCoder	(	std::string const &	template_fn,
		Engine::FIXVersion	protocolVersion )

Creates FastCoder It is user's responsibility to destroy FastCoder instance.

◆ createFastDecoder() [1/2]

FastDecoder * Engine::FixEngine::createFastDecoder	(	std::string const &	template_fn,
		Engine::FIXVersion	appProtocolVersion,
		Engine::FIXVersion	scpProtocolVersion )

Creates FastDecoder It is user's responsibility to destroy FastDecoder instance.

◆ createFastDecoder() [2/2]

FastDecoder * Engine::FixEngine::createFastDecoder	(	std::string const &	template_fn,
		Engine::FIXVersion	protocolVersion )

Creates FastDecoder It is user's responsibility to destroy FastDecoder instance.

◆ createFastSession() [1/5]

Session * Engine::FixEngine::createFastSession	(	std::string const &	templateFn,
		Application *	pApp,
		const SessionId &	sessionId,
		FIXVersion	appVer,
		const FastSessionExtraParameters *	pParam = NULL )

Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

◆ createFastSession() [2/5]

Session * Engine::FixEngine::createFastSession	(	std::string const &	templateFn,
		Application *	pApp,
		const SessionId &	sessionId,
		FIXVersion	appVer,
		FIXVersion	scpVer,
		const FastSessionExtraParameters *	pParam = NULL )

Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

◆ createFastSession() [3/5]

Session * Engine::FixEngine::createFastSession	(	std::string const &	templateFn,
		Application *	pApp,
		const std::string &	senderCompID,
		const std::string &	targetCompID,
		FIXVersion	appVer,
		const FastSessionExtraParameters *	pParam = NULL )

Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

◆ createFastSession() [4/5]

Session * Engine::FixEngine::createFastSession	(	std::string const &	templateFn,
		Application *	pApp,
		const std::string &	senderCompID,
		const std::string &	targetCompID,
		FIXVersion	appVer,
		const SessionExtraParameters *	pParam,
		const MessageStorageType	storageType = default_storageType )

Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

Deprecated: This version of the method is deprecated. Use another overloads.

◆ createFastSession() [5/5]

Session * Engine::FixEngine::createFastSession	(	std::string const &	templateFn,
		Application *	pApp,
		const std::string &	senderCompID,
		const std::string &	targetCompID,
		FIXVersion	appVer,
		FIXVersion	scpVer,
		const FastSessionExtraParameters *	pParam = NULL )

Creates FIX-over-FAST session It is user's responsibility to call Session::release method.

◆ createFixParser() [1/8]

ParserID Engine::FixEngine::createFixParser	(	DictionaryID const &	scpProtocolName,
		DictionaryID const &	appProtocol )

Creates FIXT11 protocol using loaded protocol definition files.

Parameters

[in]	scpProtocolName	Protocol name (attribute 'id' in the XML file) to create parser for. Must be FIXT 1.1 or it's customization
[in]	appProtocol	Application level protocol name.

Returns: unique parser ID.

◆ createFixParser() [2/8]

ParserID Engine::FixEngine::createFixParser	(	DictionaryID const &	scpProtocolName,
		FixVersionToProtocolName const *	appProtocols )

◆ createFixParser() [3/8]

ParserID Engine::FixEngine::createFixParser	(	DictionaryID const &	scpProtocolName,
		nullptr_t	appProtocols )

◆ createFixParser() [4/8]

ParserID Engine::FixEngine::createFixParser	(	DictionaryID const &	scpProtocolName,
		ProtocolNames const *	appProtocols = NULL )

Creates protocol using loaded protocol definition files.

Parameters

[in]	scpProtocolName	Protocol name (attribute 'id' in the XML file) to create parser for.
[in]	appProtocols	Set of application level protocols. Used if SCP protocol is FIXT 1.1 or it's customization.

Returns: unique parser ID.

◆ createFixParser() [5/8]

ParserID Engine::FixEngine::createFixParser	(	ParserName const &	parserName,
		DictionaryID const &	scpProtocolName,
		DictionaryID	appProtocol )

Creates FIXT11 protocol using loaded protocol definition files.

Parameters

[in]	parserName	Unique parser name that will be assigned to the new parser.
[in]	scpProtocolName	Transport protocol name (attribute 'id' in the XML file) to create parser for. Must be FIXT 1.1 or it's customization
[in]	appProtocol	Application level protocol name.

Returns: unique parser ID.

◆ createFixParser() [6/8]

ParserID Engine::FixEngine::createFixParser	(	ParserName const &	parserName,
		DictionaryID const &	scpProtocolName,
		FixVersionToProtocolName const *	appProtocols )

◆ createFixParser() [7/8]

ParserID Engine::FixEngine::createFixParser	(	ParserName const &	parserName,
		DictionaryID const &	scpProtocolName,
		nullptr_t	appProtocols )

◆ createFixParser() [8/8]

ParserID Engine::FixEngine::createFixParser	(	ParserName const &	parserName,
		DictionaryID const &	scpProtocolName,
		ProtocolNames const *	appProtocols )

Creates FIXT11 protocol using loaded protocol definition files.

Parameters

[in]	parserName	Unique parser name that will be assigned to the new parser.
[in]	scpProtocolName	Transport protocol name (attribute 'id' in the XML file) to create parser for. Must be FIXT 1.1 or it's customization
[in]	appProtocols	Set of application level protocols.

Returns: unique parser ID.

◆ createFortsApplication() [1/2]

Forts::FortsApplication * Engine::FixEngine::createFortsApplication	(	Forts::FortsApplicationParams const &	params,
		Forts::FortsApplicationListener *	appListener = NULL )

Creates instance of the MOEX RTS FORTS FIX/FAST adapter It is user's responsibility to call Forts::MDApplication::release method.

◆ createFortsApplication() [2/2]

Forts::FortsApplication * Engine::FixEngine::createFortsApplication	(	Forts::FortsApplicationParams const &	params,
		MarketData::DataReaderAbstract *	dataReader,
		Forts::FortsApplicationListener *	appListener = NULL )

Creates instance of the MOEX RTS FORTS FIX/FAST adapter It is user's responsibility to call Forts::MDApplication::release method.

Note: For testing puproses only

◆ createGlobexApplication() [1/2]

Globex2::GlobexApplication * Engine::FixEngine::createGlobexApplication	(	Globex2::GlobexApplicationParams const &	params,
		Globex2::GlobexApplicationListener *	appListener = NULL )

Creates instance of the CME Globex FIX/FAST adapter v.2 It is user's responsibility to call Globex::MDApplication::release method.

◆ createGlobexApplication() [2/2]

Globex2::GlobexApplication * Engine::FixEngine::createGlobexApplication	(	Globex2::GlobexApplicationParams const &	params,
		MarketData::DataReaderAbstract *	dataReader,
		Globex2::GlobexApplicationListener *	appListener = NULL )

Creates instance of the CME Globex FIX/FAST adapter v.2 It is user's responsibility to call Globex::MDApplication::release method.

Note: For testing purposes only.

◆ createGlobexSbeApplication() [1/2]

GlobexSbe::GlobexApplication * Engine::FixEngine::createGlobexSbeApplication	(	GlobexSbe::GlobexApplicationParams const &	params,
		GlobexSbe::GlobexApplicationListener *	appListener = NULL )

Creates instance of the CME Globex SBE adapter It is user's responsibility to call GlobexSbe::MDApplication::release method.

Parameters

params	application parameters
appListener	application observer

Returns: Globex SBE application instance

◆ createGlobexSbeApplication() [2/2]

GlobexSbe::GlobexApplication * Engine::FixEngine::createGlobexSbeApplication	(	GlobexSbe::GlobexApplicationParams const &	params,
		MarketData::DataReaderAbstract *	dataReader,
		GlobexSbe::GlobexApplicationListener *	appListener = NULL )

Creates instance of the CME Globex SBE adapter It is user's responsibility to call GlobexSbe::MDApplication::release method.

Parameters

params	application parameters
appListener	application observer

Returns: Globex SBE application instance

◆ createInitiator()

Session * Engine::FixEngine::createInitiator	(	Application *	pApp,
		const std::string &	senderCompID,
		const std::string &	targetCompID,
		ParserID	scpID,
		const SessionExtraParameters *	pParam = NULL )

Creates FIX initiator.

This session is experimental.

Parameters

port	Listen TCP port
pApp	Session event listener
senderCompID	SenderCompID of the session.
targetCompID	TargetCompID of the session.
scpID	FIX session control protocol identifier.
pParam	an option session parameters, can be NULL.

Warning: This session is experimental.

◆ createMarketDepthApplication()

Cboe::MarketDepth::CboeMarketDepthApplication * Engine::FixEngine::createMarketDepthApplication	(	Cboe::MarketDepth::CboeMarketDepthApplicationParams const &	params,
		MarketData::DataReaderAbstract *	dataReader,
		Cboe::MarketDepth::CboeMarketDepthApplicationListener *	appListener = NULL )

Note: For testing purposes only.

◆ createMDApplication() [1/2]

Globex::MDApplication * Engine::FixEngine::createMDApplication	(	Globex::MDApplicationParams const &	params,
		Globex::DataReaderAbstract *	dataReader,
		Globex::MDApplicationListener *	appListener = NULL )

Creates instance of the CME Globex FIX/FAST adapter It is user's responsibility to call Globex::MDApplication::release method.

Note: For testing purposes only.

◆ createMDApplication() [2/2]

Globex::MDApplication * Engine::FixEngine::createMDApplication	(	Globex::MDApplicationParams const &	params,
		Globex::MDApplicationListener *	appListener = NULL )

Creates instance of the CME Globex FIX/FAST adapter It is user's responsibility to call Globex::MDApplication::release method.

◆ createMitApplication() [1/2]

Mit::Application * Engine::FixEngine::createMitApplication	(	Mit::ConnectionManager *	connectionManager,
		const std::string &	configurationFilename )

Creates an instance of the MilleniumIT Market Data Adapter.

The application should be destroyed with Application::release(). connectionManager should stay alive until Application::release() is called. connectionManager can be 0 to create and use the default implementation.

◆ createMitApplication() [2/2]

Mit::Application * Engine::FixEngine::createMitApplication	(	Mit::ConnectionManager *	connectionManager,
		const std::string &	name,
		const Mit::ApplicationOptions &	applicationOptions )

Creates an instance of the MilleniumIT Market Data Adapter.

The application should be destroyed with Application::release(). connectionManager should stay alive until Application::release() is called. connectionManager can be 0 to create and use the default implementation.

◆ createProtocol()

ParserID Engine::FixEngine::createProtocol	(	std::string const &	name,
		FIXVersion	baseVer,
		std::string const &	additionalXml )

Register new custom FIX Protocol and returns its identifier.

Parameters

name	Unique name of the protocol
baseVer	Base FIX Version
additionalXml	FIX Protocol customization file

Exceptions

Utils::Exception If protocol with given name already exists or additionalXml points to default additional.xml file.

Returns: Unique FIX protocol identifier

Deprecated: Use Engine::FixEngine::loadProtocolFile and Engine::FixEngine::createFixParser methods.

◆ createSession() [1/6]

Session * Engine::FixEngine::createSession	(	Application *	pApp,
		const SessionId &	sessionId,
		FIXVersion	appVer = NA,
		const SessionExtraParameters *	pParam = NULL,
		const MessageStorageType	storageType = default_storageType,
		UnderlyingProtocol	underlyingProtocolType = FIX_TCP )

Creates a new FIX Session.

It is user's responsibility to call Session::release method.

Parameters

pApp	a pointer to the Application that will process the incoming messages.
sessionId	Session Identifier
appVer	Application FIX protocol version or default application FIX protocol in case of FIXT 1.1 session.
pParam	an option session parameters, can be NULL.
storageType	- type of the message storage

Warning: Do not delete the Application while the session is not terminated.

Note: two sessions with the same values of senderCompID and targetCompID can not be created.

Returns: a pointer to the created session.

◆ createSession() [2/6]

Session * Engine::FixEngine::createSession	(	Application *	pApp,
		const SessionId &	sessionId,
		ParserID	scpID,
		const SessionExtraParameters *	pParam = NULL,
		const MessageStorageType	storageType = default_storageType,
		ProtocolIndex	defaultAppProtocol = NA )

Creates a new FIX Session.

It is user's responsibility to call Session::release method.

Parameters

pApp	a pointer to the Application that will process the incoming messages.
sessionId	Session Identifier
scpID	FIX session control parser identifier.
pParam	an option session parameters, can be NULL.
storageType	Message storage type
defaultAppProtocol	Default application FIX protocol version. Required if scpID points to FIXT 1.1 protocol.

Warning: Do not delete the Application while the session is not terminated.

Note: two sessions with the same values of senderCompID and targetCompID can not be created.

Returns: a pointer to the created session.

◆ createSession() [3/6]

Session * Engine::FixEngine::createSession	(	Application *	pApp,
		const SessionId &	sessionId,
		ParserName const &	parserName,
		const SessionExtraParameters *	pParam = NULL,
		const MessageStorageType	storageType = default_storageType,
		FIXVersion	defaultAppProtocol = NA )

Creates a new FIX Session.

It is user's responsibility to call Session::release method.

Parameters

pApp	a pointer to the Application that will process the incoming messages.
sessionId	Session Identifier
parserName	Name of the parser or parser template string,

See also: Engine::FIXPropertiesNames::PARSERS_NAMES_LIST FIX Parser for this should be created.; Engine::FixEngine::createFixParser.

Parameters

pParam	an option session parameters, can be NULL.
storageType	- type of the message storage
defaultAppProtocol	Default application FIX protocol version. Required if underlyingProtocolType equals FIXT11_TCP or parserID points to FIXT 1.1 protocol.

Warning: Do not delete the Application while the session is not terminated.

Note: two sessions with the same values of senderCompID and targetCompID can not be created.

Returns: a pointer to the created session.

◆ createSession() [4/6]

Session * Engine::FixEngine::createSession	(	Application *	pApp,
		const std::string &	senderCompID,
		const std::string &	targetCompID,
		FIXVersion	appVer = NA,
		const SessionExtraParameters *	pParam = NULL,
		const MessageStorageType	storageType = default_storageType,
		UnderlyingProtocol	underlyingProtocolType = FIX_TCP )

Creates a new FIX Session.

It is user's responsibility to call Session::release method.

Parameters

pApp	a pointer to the Application that will process the incoming messages.
senderCompID	SenderCompID of the session.
targetCompID	TargetCompID of the session.
appVer	Application FIX protocol version or default application FIX protocol in case of FIXT 1.1 session.
pParam	an option session parameters, can be NULL.
storageType	- type of the message storage

Warning: Do not delete the Application while the session is not terminated.

Note: two sessions with the same values of senderCompID and targetCompID can not be created.

Returns: a pointer to the created session.

◆ createSession() [5/6]

Session * Engine::FixEngine::createSession	(	Application *	pApp,
		const std::string &	senderCompID,
		const std::string &	targetCompID,
		ParserID	scpID,
		const SessionExtraParameters *	pParam = NULL,
		const MessageStorageType	storageType = default_storageType,
		ProtocolIndex	defaultAppProtocol = NA )

Creates a new FIX Session.

It is user's responsibility to call Session::release method.

Parameters

pApp	a pointer to the Application that will process the incoming messages.
senderCompID	SenderCompID of the session.
targetCompID	TargetCompID of the session.
scpID	FIX session control parser identifier.
pParam	an option session parameters, can be NULL.
storageType	Message storage type
defaultAppProtocol	Default application FIX protocol version. Required if scpID points to FIXT 1.1 protocol.

Warning: Do not delete the Application while the session is not terminated.

Note: two sessions with the same values of senderCompID and targetCompID can not be created.

Returns: a pointer to the created session.

◆ createSession() [6/6]

Session * Engine::FixEngine::createSession	(	Application *	pApp,
		const std::string &	senderCompID,
		const std::string &	targetCompID,
		ParserName const &	parserName,
		const SessionExtraParameters *	pParam = NULL,
		const MessageStorageType	storageType = default_storageType,
		FIXVersion	defaultAppProtocol = NA )

Creates a new FIX Session.

It is user's responsibility to call Session::release method.

Parameters

pApp	a pointer to the Application that will process the incoming messages.
senderCompID	SenderCompID of the session.
targetCompID	TargetCompID of the session.
parserName	Name of the parser or parser template string,

See also: Engine::FIXPropertiesNames::PARSERS_NAMES_LIST FIX Parser for this should be created.; Engine::FixEngine::createFixParser.

Parameters

pParam	an option session parameters, can be NULL.
storageType	- type of the message storage
defaultAppProtocol	Default application FIX protocol version. Required if underlyingProtocolType equals FIXT11_TCP or parserID points to FIXT 1.1 protocol.

Warning: Do not delete the Application while the session is not terminated.

Note: two sessions with the same values of senderCompID and targetCompID can not be created.

Returns: a pointer to the created session.

◆ createSpectraApplication() [1/2]

Spectra::SpectraApplication * Engine::FixEngine::createSpectraApplication	(	Spectra::SpectraApplicationParams const &	params,
		MarketData::DataReaderAbstract *	dataReader,
		Spectra::SpectraApplicationListener *	appListener = NULL )

Creates instance of the MOEX RTS SPECTRA FIX/FAST adapter It is user's responsibility to call Spectra::MDApplication::release method.

Note: For testing puproses only

◆ createSpectraApplication() [2/2]

Spectra::SpectraApplication * Engine::FixEngine::createSpectraApplication	(	Spectra::SpectraApplicationParams const &	params,
		Spectra::SpectraApplicationListener *	appListener = NULL )

Creates instance of the MOEX RTS SPECTRA FIX/FAST adapter It is user's responsibility to call Spectra::MDApplication::release method.

◆ destroy()

static void Engine::FixEngine::destroy ( )

static

Destroys the instance of this class.

Note: Must be called after the using of FIX Engine to free the allocated resources.

◆ findParser()

ParserID Engine::FixEngine::findParser ( const ParserDescription & parserDescription ) const

Finds registered parser id by partially filled parser desription.

Parameters

[in] parserDescription partially filled parser desription

Returns: parser id or Engine::INVALID_PARSER_ID.

◆ getAdminApplication()

AdminApplication * Engine::FixEngine::getAdminApplication ( )

Returns administrative application.

If there is no registered custom application, embedded is returned.

◆ getAppProtocolName()

DictionaryID const * Engine::FixEngine::getAppProtocolName	(	ParserID	parserID,
		ProtocolIndex	protocolIndex ) const

Returns application protocol name for given parser and protocol.

Parameters

[in]	parserID	Unique parser ID
[in]	protocolIndex	protocol index in the parser

Exceptions

Utils::Exception If parser with given ID or protocol in the parser is not found.

Returns: Application protocol name.

◆ getBaseProtocol()

FIXVersion Engine::FixEngine::getBaseProtocol ( ParserID parserID ) const

Returns base FIX protocol version.

Exceptions

Utils::Exception If protocol with given ID is not found.

Returns: base FIX protocol version.

◆ getDictionary()

FixDictionary2::Dictionary const * Engine::FixEngine::getDictionary ( ) const

Returns reference to protocol dictionary.

◆ getEnginePropertiesDefaults()

static const EngineProperties Engine::FixEngine::getEnginePropertiesDefaults ( )

static

Retrieves properties defaults.

Returns: FIX Engine configuration parameters

◆ getEngineVersion()

static std::string Engine::FixEngine::getEngineVersion ( )

static

Returns version of the FixEngine.

Returns: version of the FixEngine

◆ getLicenseExpirationDate()

std::string Engine::FixEngine::getLicenseExpirationDate ( )

Returns license expiration date in the 'YYYY-MM-DD' format.

Returns: license expiration date

◆ getListenPort()

int Engine::FixEngine::getListenPort ( ) const

Returns engine listen port number.

Note: if the value is 0 then the communication level must be disabled.

◆ getListenPorts()

ListenPorts Engine::FixEngine::getListenPorts ( ) const

Returns engine listen ports.

Note: if the number of the ports is 0 then the communication level must be disabled.

◆ getParserDescription()

ParserDescription Engine::FixEngine::getParserDescription ( Engine::ParserID parserID ) const

Returns parser description for given parser id.

Parameters

parserID unique parser id

Returns: ParserDescription

◆ getParserID()

ParserID Engine::FixEngine::getParserID ( ParserName const & name ) const

Returns unique parser ID.

Parameters

[in] Unique parser name

Returns: unique parser ID or INVALID_PARSER_ID if not found.

◆ getParserName()

ParserName const & Engine::FixEngine::getParserName ( ParserID parserID ) const

Returns unique parser name.

Parameters

[in] parserID Unique parser ID

Exceptions

Utils::Exception If parser with given ID is not found.

Returns: unique parser name.

◆ getParsers()

ParserIDToParserNamePtr Engine::FixEngine::getParsers ( ) const

Returns set of registered parsers include custom parsers.

Returns: set of parsers.

◆ getProperties()

const FAProperties * Engine::FixEngine::getProperties ( ) const

Returns settings.

◆ getProtocol()

FixDictionary2::ProtocolT::CPtr Engine::FixEngine::getProtocol ( std::string const & protocolName ) const

Returns registered protocol by protocol name.

Parameters

protocolName name of protocol

Exceptions

Utils::Exception if protocol for given name is not found.

Returns: pointer to protocol

◆ getProtocolBaseVersion()

FIXVersion Engine::FixEngine::getProtocolBaseVersion ( std::string const & protocolName ) const

Returns base version of registered protocol by protocol name.

Parameters

protocolName name of protocol

Exceptions

Utils::Exception if protocol for given name is not found.

Returns: base version of registered protocol

◆ getProtocolID()

ParserID Engine::FixEngine::getProtocolID ( const std::string & name ) const

inline

Returns unique parser ID.

Parameters

[in] Unique parser name

Exceptions

Utils::Exception If parser with given name is not found.

Returns: unique parser ID.

Deprecated: Use Engine::FixEngine::getParserID().

◆ getProtocolName()

Engine::AsciiString Engine::FixEngine::getProtocolName ( ParserID parserID ) const

Returns unique parser name.

Parameters

[in] parserID Unique parser ID

Exceptions

Utils::Exception If parser with given ID is not found.

Deprecated: Use Engine::FixEngine::getParserName().

Returns: unique parser name.

◆ getProtocols()

ProtocolIndexToProtocolName const * Engine::FixEngine::getProtocols ( ParserID parserID ) const

Returns set of application level protocols for given parser.

Parameters

[in] parserID Unique parser ID

Exceptions

Utils::Exception If parser with given ID is not found.

Returns: set of application level protocols.

◆ getScheduler()

System::SchedulerPtr Engine::FixEngine::getScheduler ( ) const

Returns engine's scheduler used to run cobfigured schedules.

◆ getScpProtocolName()

DictionaryID const * Engine::FixEngine::getScpProtocolName ( ParserID parserID ) const

Returns transport protocol name for given parser.

Parameters

[in] parserID Unique parser ID

Exceptions

Utils::Exception If parser with given ID is not found.

Returns: Transport protocol name.

◆ getSession() [1/2]

Session * Engine::FixEngine::getSession ( const SessionId & sessionId )

Searches for a session by sessionId consisting of senderCompID, targetCompID and session qualifier.

Session can be found after Session::connect call. Calls addRef before returning the pointer, it is user's responsibility to call Session::release method.

Parameters

sessionId Session Identifier

Returns: a pointer to the session or NULL if session was not found.

◆ getSession() [2/2]

Session * Engine::FixEngine::getSession	(	const std::string &	senderCompID,
		const std::string &	targetCompID )

Searches for a session with given senderCompID/targetCompID with empty session qualifier.

Use overloaded method with SessionId parameter to get session with qualifier. Session can be found after Session::connect call Calls addRef before returning the pointer, it is user's responsibility to call Session::release method.

Parameters

senderCompID	SenderCompID of the session.
targetCompID	TargetCompID of the session.

Returns: a pointer to the session or NULL if session was not found.

◆ getSessionsManager()

Engine::SessionsManager * Engine::FixEngine::getSessionsManager ( )

Returns the current SessionsManager.

◆ getStatistics()

void Engine::FixEngine::getStatistics ( Statistics * apS )

Returns the statistical information.

Parameters

[out] apS Instance of Statistics to store result.

◆ getUnregisteredAcceptorSessionStorageType()

MessageStorageType Engine::FixEngine::getUnregisteredAcceptorSessionStorageType ( ) const

Returns the default unregistered session's storage type.

Returns: type storage type that will be used in new sessions.

◆ init() [1/3]

static FixEngine * Engine::FixEngine::init	(	const EngineProperties &	engineProperties,
		const std::string &	licenseKey = "",
		bool	initUtilsLogger = true,
		const SSLCustomContextProperties &	customSSLContextProperties = SSLCustomContextProperties() )

static

Initializes the Engine.

Parameters

engineProperties	Engine parameters. List of parameters can be find in the B2BITS_FAProperties.h file.
licenseKey	License key
initUtilsLogger	Specifies either FixEngine should initalize LogSystem. Pass true to force FixEngine to initialize LogSystem; false otherwise.
customSSLContextProperties	SSLCustomContextProperties interface used to custom SSL configuration if any.

Returns: pointer to an instance of this class.

Note: Must be called before any other method of this library.

See also: Utils::Log::LogSystem

◆ init() [2/3]

static FixEngine * Engine::FixEngine::init	(	const std::string &	propertiesFileName = "",
		int	listenPort = -1,
		const std::string &	engineRoot = "",
		const std::string &	additionalFields = "",
		const std::string &	licenseKey = "",
		bool	initUtilsLogger = true,
		const SSLCustomContextProperties &	customSSLContextProperties = SSLCustomContextProperties() )

static

Initializes the Engine.

Parameters

propertiesFileName	the FIX Engine configuration parameters file name. If it is equal to "", then "./engine.properties" is used.
listenPort	Engine's listen port. Overrides the value from the properties file. If it is equal to -1 then the value from the properties file is used.
engineRoot	The top of the directory tree under which the engine's configuration, and log files are kept. Do NOT add a slash at the end of the directory path. Overrides the value from the properties file. If it is equal to "", then the value from the properties file is used.
additionalFields	Specifies additional messages fields.
licenseKey	License key
initUtilsLogger	Specifies either FixEngine should initalize LogSystem. Pass true to force FixEngine to initialize LogSystem; false otherwise.
customSSLContextProperties	SSLCustomContextProperties interface used to custom SSL configuration if any.

Returns: pointer to an instance of this class.

Note: Must be called before any other method of this library.

See also: Utils::Log::LogSystem

◆ init() [3/3]

static FixEngine * Engine::FixEngine::init ( InitParameters const & params )

static

Initializes the Engine.

Parameters

params Engine parameters.

Returns: pointer to an instance of this class.

Note: Must be called before any other method of this library.

◆ initialized()

static bool Engine::FixEngine::initialized ( )

static

Returns true if FixEngine was initialized; false otherwise.

◆ loadProtocolFile()

FixDictionary2::Dictionary::DictionariesInfo Engine::FixEngine::loadProtocolFile ( std::string const & fileName )

Loads protocol definition/customization file.

Parameters

[in] fileName Path to the protocol file

◆ registerAdminApplication()

void Engine::FixEngine::registerAdminApplication ( AdminApplication * app )

Register administrative application.

Parameters

app	custom administrative application.

Exceptions

Utils::Exception if administrative application already registered.

◆ registerEventListener()

void Engine::FixEngine::registerEventListener ( Engine::EventListener * apListener )

Registers the given EventListener with FixEngine.

Parameters

apListener EventListener

◆ registerSessionsManager()

void Engine::FixEngine::registerSessionsManager ( SessionsManager * apManager )

Registers SessionsManager with the engine.

Parameters

apManager Instance of SessionsManager.

◆ reset_revision()

static void Engine::FixEngine::reset_revision ( const char * r )

static

Using by FA to log real revision number, to avoid static relink.

◆ setAdditionalFields()

static void Engine::FixEngine::setAdditionalFields	(	const std::string &	propertiesFileName = "",
		const std::string &	engineRoot = "",
		const std::string &	additionalFields = "" )

static

Initializes the additional fields.

Parameters

propertiesFileName	the FIX Engine configuration parameters file name. If it is equal to "", then "./engine.properties" is used.
engineRoot	The top of the directory tree under which the engine's configuration, and log files are kept. Do NOT add a slash at the end of the directory path. Overrides the value from the properties file. If it is equal to "", then the value from the proterties file is used.
additionalFields	Specifies additional messages fields.

Note: Do not use it with init() method.

◆ setUnregisteredAcceptorSessionStorageType()

void Engine::FixEngine::setUnregisteredAcceptorSessionStorageType ( const MessageStorageType type )

Sets the default unregistered session's storage type.

Parameters

type	storage type that will be used in new sessions.

◆ singleton()

static FixEngine * Engine::FixEngine::singleton ( )

static

Returns an instance of this class.

Returns: pointer to an instance of this class.

See also: init()

◆ startListeningIncomingConnections()

void Engine::FixEngine::startListeningIncomingConnections ( )

Makes the engine listen to incoming connections.

See also: Engine::FixEngine::InitParameters::startListeningIncomingConnections_

◆ stop()

void Engine::FixEngine::stop ( )

Stops the engine's worker threads.

◆ stopListeningIncomingConnections()

void Engine::FixEngine::stopListeningIncomingConnections ( )

Pauses the engine listen to incoming connections.

◆ unregisterEventListener()

bool Engine::FixEngine::unregisterEventListener ( Engine::EventListener * apListener )

Unregisters the given EventListener.

Parameters

apListener EventListener

Returns: true if the EventListener was found, otherwise false.

Classes

Public Member Functions

Static Public Member Functions

Detailed Description

Member Function Documentation

◆ _impl()

◆ backupLogFile()

◆ cancelScheduledSessionRestart()

◆ clearAdditionalFields()

◆ createAcceptor()

◆ createBatsApplication()

◆ createBovespaApplication() [1/2]

◆ createBovespaApplication() [2/2]

◆ createCboeCmi2Initiator()

◆ createCboeCsmApplication() [1/2]

◆ createCboeCsmApplication() [2/2]

◆ createCboeMarketDepthApplication()

◆ createCmeMdpMarketDataService()

◆ createCqgMDApplication()

◆ createFastCoder() [1/2]

◆ createFastCoder() [2/2]

◆ createFastDecoder() [1/2]

◆ createFastDecoder() [2/2]

◆ createFastSession() [1/5]

◆ createFastSession() [2/5]

◆ createFastSession() [3/5]

◆ createFastSession() [4/5]

◆ createFastSession() [5/5]

◆ createFixParser() [1/8]

◆ createFixParser() [2/8]

◆ createFixParser() [3/8]

◆ createFixParser() [4/8]

◆ createFixParser() [5/8]

◆ createFixParser() [6/8]

◆ createFixParser() [7/8]

◆ createFixParser() [8/8]

◆ createFortsApplication() [1/2]

◆ createFortsApplication() [2/2]

◆ createGlobexApplication() [1/2]

◆ createGlobexApplication() [2/2]

◆ createGlobexSbeApplication() [1/2]

◆ createGlobexSbeApplication() [2/2]

◆ createInitiator()

◆ createMarketDepthApplication()

◆ createMDApplication() [1/2]

◆ createMDApplication() [2/2]

◆ createMitApplication() [1/2]

◆ createMitApplication() [2/2]

◆ createProtocol()

◆ createSession() [1/6]

◆ createSession() [2/6]

◆ createSession() [3/6]

◆ createSession() [4/6]

◆ createSession() [5/6]

◆ createSession() [6/6]

◆ createSpectraApplication() [1/2]

◆ createSpectraApplication() [2/2]

◆ destroy()

◆ findParser()

◆ getAdminApplication()

◆ getAppProtocolName()

◆ getBaseProtocol()

◆ getDictionary()

◆ getEnginePropertiesDefaults()

◆ getEngineVersion()

◆ getLicenseExpirationDate()

◆ getListenPort()

◆ getListenPorts()

◆ getParserDescription()

◆ getParserID()

◆ getParserName()

◆ getParsers()

◆ getProperties()

◆ getProtocol()

◆ getProtocolBaseVersion()

◆ getProtocolID()

◆ getProtocolName()

◆ getProtocols()

◆ getScheduler()

◆ getScpProtocolName()