| 137 | QueueServiceImpl() {} |
| 138 | virtual ~QueueServiceImpl() {} |
| 139 | void start(google::protobuf::RpcController* cntl_base, |
| 140 | const HttpRequest*, |
| 141 | HttpResponse*, |
| 142 | google::protobuf::Closure* done) { |
| 143 | brpc::ClosureGuard done_guard(done); |
| 144 | brpc::Controller* cntl = |
| 145 | static_cast<brpc::Controller*>(cntl_base); |
| 146 | cntl->response_attachment().append("queue started"); |
| 147 | } |
| 148 | void stop(google::protobuf::RpcController* cntl_base, |
| 149 | const HttpRequest*, |
| 150 | HttpResponse*, |
no test coverage detected