| 871 | } |
| 872 | |
| 873 | bool Consumer::SkipHandle(const comm::proto::ConsumerContext &cc, const comm::proto::QItem &item) { |
| 874 | if (!(item.sub_ids() & (1ULL << (cc.sub_id() - 1)))) return true; |
| 875 | return false; |
| 876 | } |
| 877 | |
| 878 | comm::RetCode Consumer::Handle(const comm::proto::ConsumerContext &cc, |
| 879 | comm::proto::QItem &item, comm::HandleResult &handle_result) { |