| 62 | } |
| 63 | |
| 64 | phxqueue::comm::RetCode |
| 65 | Consumer::Add(phxqueue::comm::proto::AddRequest &req, |
| 66 | phxqueue::comm::proto::AddResponse &resp) { |
| 67 | phxqueue::producer::ProducerOption opt; |
| 68 | phxqueue_phxrpc::producer::Producer producer(opt); |
| 69 | auto ret = producer.SelectAndAdd(req, resp, nullptr, nullptr); |
| 70 | if (phxqueue::comm::RetCode::RET_OK != ret) { |
| 71 | QLErr("Producer::SelectAndAdd ret %d", phxqueue::comm::as_integer(ret)); |
| 72 | } |
| 73 | return ret; |
| 74 | } |
| 75 | |
| 76 | phxqueue::comm::RetCode |
| 77 | Consumer::GetAddrScale(const phxqueue::comm::proto::GetAddrScaleRequest &req, |
nothing calls this directly
no test coverage detected