Method GetQueueInfoByQueue

phxqueue/config/topicconfig.cpp:447–453

}

comm::RetCode TopicConfig::GetQueueInfoByQueue(const int queue, shared_ptr<const proto::QueueInfo> &queue_info) const {
    queue_info = nullptr;
    auto &&it = impl_->queue2queue_info_id.find(queue);
    if (it == impl_->queue2queue_info_id.end()) return comm::RetCode::RET_ERR_RANGE_QUEUE;

    return GetQueueInfoByQueueInfoID(it->second, queue_info);
}

comm::RetCode TopicConfig::GetQueueInfoByQueueInfoID(const int queue_info_id, shared_ptr<const proto::QueueInfo> &queue_info) const {
    queue_info = nullptr;