Method OnMaxLoopCheckUnpass

phxqueue/comm/breakpoint.h:58–58

    virtual void OnMaxLoopCheck(const int topic_id) {}
    virtual void OnMaxLoopCheckUnpass(const int topic_id) {}
    virtual void OnMaxLoopCheckPass(const int topic_id) {}

    virtual void OnConsume(const proto::ConsumerContext &cc, const std::vector<std::shared_ptr<proto::QItem>> &items) {}