Method GetAllConsumer

phxqueue/config/consumerconfig.cpp:90–95

}

comm::RetCode ConsumerConfig::GetAllConsumer(std::vector<shared_ptr<const proto::Consumer>> &consumers) const {
    for (auto &&it : impl_->addr2consumer) {
        consumers.push_back(it.second);
    }
    return comm::RetCode::RET_OK;
}

comm::RetCode ConsumerConfig::GetConsumerByAddr(const comm::proto::Addr &addr, shared_ptr<const proto::Consumer> &consumer) const {
    auto &&encoded_addr = comm::utils::EncodeAddr(addr);