Method GetConsumerConfig

phxqueue/config/globalconfig.cpp:179–191

}

comm::RetCode GlobalConfig::GetConsumerConfig(const int topic_id, shared_ptr<const ConsumerConfig> &consumer_config) {
    consumer_config = nullptr;

    auto &&it = impl_->topic_id2consumer_config.find(topic_id);
    if (it == impl_->topic_id2consumer_config.end()) {
        NeedRebuild();
        return comm::RetCode::RET_ERR_RANGE_TOPIC;
    }
    if (!it->second) return comm::RetCode::RET_ERR_RANGE_TOPIC;
    it->second->Load();
    consumer_config = it->second;
    return comm::RetCode::RET_OK;
}

comm::RetCode GlobalConfig::GetStoreConfig(const int topic_id, shared_ptr<const StoreConfig> &store_config) {
    store_config = nullptr;