Method HandleRoutineFunc

phxqueue/consumer/consumer.cpp:303–334

void Consumer::HandleRoutineFunc(const int idx) {
    auto &&item = impl_->items[idx];
    auto &&handle_result = impl_->handle_results[idx];

    comm::ConsumerConsumeBP::GetThreadInstance()->OnHandleRoutineFunc(impl_->cc, idx);

    if (!item) {
        QLErr("item null. idx %d", idx);
        handle_result = comm::HandleResult::RES_ERROR;
        return;
    }

    if (SkipHandle(impl_->cc, *item)) {
        comm::ConsumerConsumeBP::GetThreadInstance()->OnSkipHandle(impl_->cc, *item);
        QLInfo("Handle skip handle_id %d ori_pub_id %d pub_id %d sub_ids %" PRIu64 " hash %" PRIu64 " uin %" PRIu64,
               item->meta().handle_id(), item->meta().pub_id(), item->pub_id(), (uint64_t)item->sub_ids(), (uint64_t)item->meta().hash(), (uint64_t)item->meta().uin());
        handle_result = comm::HandleResult::RES_OK;
        return;
    }

    BeforeHandle(impl_->cc, *item);

    comm::RetCode ret;
    if (comm::RetCode::RET_OK != (ret = Handle(impl_->cc, *item, handle_result))) {
        QLErr("Handle ret %d", comm::as_integer(ret));
        return;
    }

    AfterHandle(impl_->cc, *item, handle_result);

    return;
}

void Consumer::BatchHandleRoutineFunc(const int idx) {
    comm::ConsumerConsumeBP::GetThreadInstance()->OnBatchHandleRoutineFunc(impl_->cc, idx);