| 132 | } |
| 133 | |
| 134 | comm::RetCode SimpleConsumer::AcquireLock(const comm::proto::AcquireLockRequest &req, |
| 135 | comm::proto::AcquireLockResponse &resp) { |
| 136 | return comm::RetCode::RET_ERR_NO_IMPL; |
| 137 | } |
| 138 | |
| 139 | void SimpleConsumer::BeforeLock(const comm::proto::ConsumerContext &cc) { |
| 140 | QLInfo("BeforeLock cc sub_id %d store_id %d queue_id %d", |