Batch handle implement. arg idx within [0, ConsumerOption::nbatch_handler).
| 173 | // Batch handle implement. |
| 174 | // arg idx within [0, ConsumerOption::nbatch_handler). |
| 175 | virtual comm::RetCode BatchHandle(const comm::proto::ConsumerContext &cc, |
| 176 | const std::vector<std::shared_ptr<comm::proto::QItem> > &items, |
| 177 | const int idx) { |
| 178 | return comm::RetCode::RET_OK; |
| 179 | } |
| 180 | |
| 181 | // Callback after the worker routine finish batch handle. |
| 182 | virtual void AfterBatchHandle(const comm::proto::ConsumerContext &cc, |
nothing calls this directly
no outgoing calls
no test coverage detected