reader
ConsumerHandler
ConsumerHandler
receive
Reader
ConsumerWriter
Broadcaster
RecordListener
RecordListener
rq
records
PersistenceWriter
rq
handler