#include <OnixS/B3/MarketData/UMDF/FeedEngine.h>
Public Member Functions | |
| SocketFeedEngine (const LoggerSettings &loggerSettings, UInt32 dataWaitTime=10, UInt32 socketBufferSize=8 *1024 *1024, WatchService &watch=UtcWatch::service()) | |
| SocketFeedEngine (UInt32 dataWaitTime=10, UInt32 socketBufferSize=8 *1024 *1024, WatchService &watch=UtcWatch::service()) | |
| NetFeedEngineProcessResult | process () |
| ~SocketFeedEngine () override | |
| Public Member Functions inherited from FeedEngine | |
| std::string | info () |
| virtual | ~FeedEngine () |
Additional Inherited Members | |
| Protected Member Functions inherited from FeedEngine | |
| FeedEngine (void *impl) | |
| FeedEngine (const FeedEngine &)=delete | |
| FeedEngine & | operator= (const FeedEngine &)=delete |
| Protected Attributes inherited from FeedEngine | |
| void *const | impl_ |
Definition at line 148 of file FeedEngine.h.
| SocketFeedEngine | ( | const LoggerSettings & | loggerSettings, |
| UInt32 | dataWaitTime = 10, | ||
| UInt32 | socketBufferSize = 8 *1024 *1024, | ||
| WatchService & | watch = UtcWatch::service() ) |
Constructor.
| loggerSettings | Defines feed engine logging settings. |
| socketBufferSize | Defines size of receiving buffer in bytes for sockets. |
| dataWaitTime | Defines amount of time Feed Engine spends on waiting for I/O while running master processing loop. Time is measured in milliseconds. |
| watch | Watch service to be used by Feed Engine. |
Watch is used by Feed Engine to assign time points to packets received from the feeds.
|
explicit |
|
override |
| NetFeedEngineProcessResult process | ( | ) |
Carries out pending actions like data retrieval and event dispatching.
This function must be invoked after each handler-associated action (i.e., start, stop).
