Method OnCountLimit

phxqueue/comm/breakpoint.h:252–252

    virtual void OnMakeAddRequestsSucc(const int topic_id, const std::vector<std::shared_ptr<proto::QItem>> &items) {}

    virtual void OnCountLimit(const int topic_id, const int pub_id, const proto::QItem &item) {}

    virtual void OnBatchRawAdd(const proto::AddRequest &req) {}
    virtual void OnBatchRawAddSucc(const proto::AddRequest &req) {}