Method QueueSelectorDefault

phxqueue/producer/selector.cpp:42–50

};

QueueSelectorDefault::QueueSelectorDefault(const int topic_id, const int pub_id, const uint64_t uin, const int count, const bool retry_switch_queue) : impl_(new QueueSelectorDefaultImpl()){
    assert(impl_);
    impl_->topic_id = topic_id;
    impl_->pub_id = pub_id;
    impl_->uin = uin;
    impl_->count = count;
    impl_->retry_switch_queue = retry_switch_queue;
    impl_->retry = 0;
}

QueueSelectorDefault::~QueueSelectorDefault() {
}