31 ONIXS_HANDLER_NAMESPACE_BEGIN
33 GlimpsePacketProcessor::GlimpsePacketProcessor(HandlerLogger* logger,
const Logging::LogFacility* parent,
MessageRepository* messageRepository) :
34 Logging::LogFacility(
"Glimpse", parent,
OnixS::Logging::LOG_LEVEL_DEBUG),
36 messageRepository_(messageRepository)
38 BOOST_ASSERT(logger_ !=
nullptr);
51 const char*
const data =
static_cast<const char*
>(packetContainer.data());
52 const size_t size = packetContainer.size();
54 BOOST_ASSERT(data !=
nullptr);
55 BOOST_ASSERT(size != 0);
57 logger_->log(ONIXS_LOG_INFO[
this] <<
"Received " << size <<
" bytes (" << Base64Source(data, size) <<
").");
67 IncomingMessage msg(reinterpret_cast<const unsigned char*>(data), static_cast<UInt16>(size));
71 ONIXS_HANDLER_NAMESPACE_END
Origin origin
the way data received
UInt16 packetMessageCount
Message sequence number.
Represents timestamp without time-zone information.
virtual ~GlimpsePacketProcessor()
const Byte * session
Session Id.
void processMessage(const DataSource &dataSource, const IncomingMessage *message)
UInt8 packetMessageNumber
Number of message in packet.
UInt64 messageSeqNum
Message sequence number.
Timestamp packetReceptionTime
Time when the packet was received by Handler from UDP, in system ticks,.
void onPacket(OnixS::HandlerCore::MarketData::FE::PacketContainer &) override