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

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

Collaboration diagram for EmdiPacketProcessor:

Public Types

typedef PacketProcessor< PacketHeaderForEMDIbase
 
- Public Types inherited from PacketProcessor< PacketHeaderForEMDI >
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

 EmdiPacketProcessor (unsigned int maxPacketWaitingTime, unsigned int inactivityWaitingTime, unsigned int outOfOrderMaxInterval, Concurrency::RecursiveMutex *lock, const boost::function< bool(PartitionId partitionId)> filterPacket)
 
- Public Member Functions inherited from PacketProcessor< PacketHeaderForEMDI >
 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

virtual bool filterPacket (const PacketHeaderForEMDI *header)
 
virtual void fillDataSource (FE::PacketContainer &packetContainer, DataSource &dataSource)
 

Detailed Description

Definition at line 31 of file EmdiPacketProcessor.h.

Member Typedef Documentation

Definition at line 33 of file EmdiPacketProcessor.h.

Constructor & Destructor Documentation

EmdiPacketProcessor ( unsigned int  maxPacketWaitingTime,
unsigned int  inactivityWaitingTime,
unsigned int  outOfOrderMaxInterval,
Concurrency::RecursiveMutex *  lock,
const boost::function< bool(PartitionId partitionId)>  filterPacket 
)
inline

Definition at line 36 of file EmdiPacketProcessor.h.

Member Function Documentation

virtual void fillDataSource ( FE::PacketContainer &  packetContainer,
DataSource dataSource 
)
inlineprotectedvirtual

Reimplemented from PacketProcessor< PacketHeaderForEMDI >.

Definition at line 54 of file EmdiPacketProcessor.h.

virtual bool filterPacket ( const PacketHeaderForEMDI header)
inlineprotectedvirtual

Reimplemented from PacketProcessor< PacketHeaderForEMDI >.

Definition at line 49 of file EmdiPacketProcessor.h.


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