| 81 | virtual void OnHandleEnd(const proto::ConsumerContext &cc, const proto::QItem &item, const HandleResult &handle_result) {} |
| 82 | virtual void OnBatchHandleRoutineFunc(const proto::ConsumerContext &cc, const int cid) {} |
| 83 | virtual void OnSkipHandle(const proto::ConsumerContext &cc, const proto::QItem &item) {} |
| 84 | }; |
| 85 | |
| 86 | class ConsumerHeartBeatLockBP { |