BetaTrader
A HFT Eco-System
Loading...
Searching...
No Matches
trading_core::MarketDataPublisher Class Reference

#include <MarketDataPublisher.h>

Collaboration diagram for trading_core::MarketDataPublisher:
Collaboration graph

Public Types

using IncrementalCallback = std::function< void(const fix::MarketDataIncrementalRefresh &)>
 
using SnapshotCallback = std::function< void(const fix::MarketDataSnapshotFullRefresh &)>
 

Public Member Functions

void addSubscription (common::Symbol symbol, common::SessionID sessionId)
 
void publishIncremental (const fix::MarketDataIncrementalRefresh &refresh)
 
void publishSnapshot (const fix::MarketDataSnapshotFullRefresh &snapshot)
 
void removeSubscription (common::SessionID sessionId)
 
void removeSubscription (common::Symbol symbol, common::SessionID sessionId)
 
void subscribeToIncrementals (IncrementalCallback callback)
 
void subscribeToSnapshots (SnapshotCallback callback)
 

Private Attributes

IncrementalCallback mIncrementalCallback
 
SnapshotCallback mSnapshotCallback
 
std::map< common::Symbol, std::vector< common::SessionID > > mSubscriptions
 

Member Typedef Documentation

◆ IncrementalCallback

◆ SnapshotCallback

Member Function Documentation

◆ addSubscription()

void trading_core::MarketDataPublisher::addSubscription ( common::Symbol  symbol,
common::SessionID  sessionId 
)
Here is the call graph for this function:
Here is the caller graph for this function:

◆ publishIncremental()

void trading_core::MarketDataPublisher::publishIncremental ( const fix::MarketDataIncrementalRefresh refresh)
Here is the call graph for this function:
Here is the caller graph for this function:

◆ publishSnapshot()

void trading_core::MarketDataPublisher::publishSnapshot ( const fix::MarketDataSnapshotFullRefresh snapshot)
Here is the call graph for this function:
Here is the caller graph for this function:

◆ removeSubscription() [1/2]

void trading_core::MarketDataPublisher::removeSubscription ( common::SessionID  sessionId)

◆ removeSubscription() [2/2]

void trading_core::MarketDataPublisher::removeSubscription ( common::Symbol  symbol,
common::SessionID  sessionId 
)
Here is the call graph for this function:
Here is the caller graph for this function:

◆ subscribeToIncrementals()

void trading_core::MarketDataPublisher::subscribeToIncrementals ( IncrementalCallback  callback)
Here is the caller graph for this function:

◆ subscribeToSnapshots()

void trading_core::MarketDataPublisher::subscribeToSnapshots ( SnapshotCallback  callback)
Here is the caller graph for this function:

Member Data Documentation

◆ mIncrementalCallback

IncrementalCallback trading_core::MarketDataPublisher::mIncrementalCallback
private

◆ mSnapshotCallback

SnapshotCallback trading_core::MarketDataPublisher::mSnapshotCallback
private

◆ mSubscriptions

std::map<common::Symbol, std::vector<common::SessionID> > trading_core::MarketDataPublisher::mSubscriptions
private

The documentation for this class was generated from the following files: