OnixS C++ Eurex T7 Market and Reference Data Interface (EMDI, RDI, EOBI) Handlers  8.1.0
API documentation
MdiPacketProcessor Struct Reference

#include </work/src/MdiPacketProcessor.h>

Collaboration diagram for MdiPacketProcessor:

Public Types

typedef PacketProcessor< PacketHeaderForMDIbase
- Public Types inherited from PacketProcessor< PacketHeaderForMDI >
typedef boost::function< void(DataSource &, const char *, size_t, size_t)> OnPacketData
typedef boost::function< void()> OnGap
typedef boost::function< void(unsigned int, unsigned int, SequenceNumber, SequenceNumber)> OnSenderCompIdChange
typedef boost::function< void()> OnInactivity
typedef boost::function< void(FE::NetFeedRole::Enum)> OnFeedInactivity

Public Member Functions

 MdiPacketProcessor (unsigned int maxPacketWaitingTime, unsigned int inactivityWaitingTime, unsigned int outOfOrderMaxInterval, Concurrency::RecursiveMutex *lock)
- Public Member Functions inherited from PacketProcessor< PacketHeaderForMDI >
 PacketProcessor (unsigned int, unsigned int, unsigned int, Concurrency::RecursiveMutex *)
virtual ~PacketProcessor ()
void reset () override
bool tryAcquire () override
void release () override
void onPacket (FE::PacketContainer &) override
void onTimeout (const FE::NetFeed &) override
void onFailure (const FE::NetFeed &, const char *) override
void subscribeOnPacketData (OnPacketData callback)
void subscribeOnGap (OnGap callback)
void subscribeOnSenderCompIdChange (OnSenderCompIdChange callback)
void subscribeOnInactivity (OnInactivity callback)
void subscribeOnFeedInactivity (OnFeedInactivity callback)

Protected Member Functions

void fillDataSource (FE::PacketContainer &packetContainer, DataSource &dataSource) override
- Protected Member Functions inherited from PacketProcessor< PacketHeaderForMDI >
virtual bool filterPacket (const PacketHeaderForMDI *)

Detailed Description

Definition at line 31 of file MdiPacketProcessor.h.

Member Typedef Documentation

Definition at line 33 of file MdiPacketProcessor.h.

Constructor & Destructor Documentation

MdiPacketProcessor ( unsigned int  maxPacketWaitingTime,
unsigned int  inactivityWaitingTime,
unsigned int  outOfOrderMaxInterval,
Concurrency::RecursiveMutex *  lock 

Definition at line 36 of file MdiPacketProcessor.h.

Member Function Documentation

void fillDataSource ( FE::PacketContainer &  packetContainer,
DataSource dataSource 

Reimplemented from PacketProcessor< PacketHeaderForMDI >.

Definition at line 47 of file MdiPacketProcessor.h.

The documentation for this struct was generated from the following file: