|
B
|
StreamReader::processPendingMessages()
|
0
|
16
|
7
|
7
|
0
|
0
|
0
|
|
A
|
Drivers\PredisDriver::readMessages()
|
0
|
12
|
5
|
?
|
1
|
0
|
1
|
|
A
|
Drivers\PredisDriver::sendMessage()
|
0
|
5
|
2
|
?
|
1
|
0
|
1
|
|
A
|
DataStreamer\StreamReader::processMessage()
|
0
|
8
|
3
|
3
|
0
|
0
|
0
|
|
A
|
DataStreamer\StreamWriter::__construct()
|
0
|
3
|
1
|
1
|
1
|
0
|
1
|
|
A
|
Drivers\RedisDriver::getClient()
|
0
|
1
|
1
|
?
|
0
|
0
|
0
|
|
A
|
DataStreamer\Data\CallableHandler::handle()
|
0
|
6
|
4
|
4
|
1
|
0
|
1
|
|
A
|
PayloadMessageConverter::convert()
|
0
|
3
|
1
|
1
|
1
|
0
|
1
|
|
A
|
FailHandler\FileLogHandler::openLogFile()
|
0
|
1
|
1
|
?
|
0
|
0
|
0
|
|
A
|
DataStreamer\Data\ArrayMessage::getType()
|
0
|
1
|
1
|
1
|
1
|
0
|
1
|
|
A
|
Data\Settings::getConsumerGroup()
|
0
|
1
|
1
|
1
|
1
|
0
|
1
|
|
A
|
Drivers\PredisDriver::acknowledge()
|
0
|
1
|
1
|
?
|
1
|
0
|
1
|
|
A
|
DataStreamer\StreamReader::runLoop()
|
0
|
3
|
2
|
6
|
0
|
0
|
0
|
|
A
|
Drivers\RedisDriver::sendMessage()
|
0
|
1
|
1
|
?
|
0
|
0
|
0
|
|
A
|
DataStreamer\StreamReader::readMessages()
|
0
|
7
|
1
|
1
|
0
|
0
|
0
|