Method OnSubDistribute

phxqueue/comm/breakpoint.h:268–268

    virtual ~ProducerSubBP() {}

    virtual void OnSubDistribute(const int topic_id, const int pub_id, const int handle_id, const uint64_t uin, const std::set<int> *sub_ids) {}
};