| 73 | virtual void OnConsumeThreadRun(const proto::ConsumerContext &cc) {} |
| 74 | virtual void OnConsumeThreadRunEnd(const proto::ConsumerContext &cc) {} |
| 75 | virtual void OnTaskDispatch(const proto::ConsumerContext &cc) {} |
| 76 | virtual void OnTaskWait(const proto::ConsumerContext &cc) {} |
| 77 | virtual void OnTaskDispatchFinish(const proto::ConsumerContext &cc) {} |
| 78 | virtual void OnMakeHandleBucket(const proto::ConsumerContext &cc) {} |