ByteStreamEmonInputSvc Node1 ByteStreamEmonInputSvc - m_totalEventCounter - m_re - m_partition - m_key - m_value - m_key_count - m_publish - m_exit - m_is_server - m_include and 32 more... + ByteStreamEmonInputSvc() + initialize() + start() + finalize() + previousEvent() + nextEvent() + currentEvent() - getIterator() - check_publish() - get_runparams() - updateHandler() Node2 ByteStreamInputSvc + ByteStreamInputSvc() + ~ByteStreamInputSvc() + nextEvent() + previousEvent() + setEvent() + currentEvent() + currentEventStatus() + getBlockIterator() + closeBlockIterator() + ready() + generateDataHeader() + positionInBlock() + validateEvent() + interfaceID() Node2->Node1 Node3 AthService - AthService() - AthService() - operator=() Node3->Node2 Node4 AthCommonMsg< Service > + msg() + msg() + msgLvl() Node4->Node3 Node5 Service Node5->Node4