Searched refs:fmq_response (Results 1 – 5 of 5) sorted by relevance
85 fmq_response = self._client.SendFmqRequest(request_msg)86 if fmq_response is not None and fmq_response.queue_id != -1:87 self._queue_id = fmq_response.queue_id113 fmq_response = self._client.SendFmqRequest(request_msg)114 if fmq_response is not None and fmq_response.success:115 self._extractReadData(fmq_response, data)144 fmq_response = self._client.SendFmqRequest(request_msg)145 if fmq_response is not None and fmq_response.success:146 self._extractReadData(fmq_response, data)172 fmq_response = self._client.SendFmqRequest(request_msg)[all …]
259 FmqResponseMessage* fmq_response) { in ProcessFmqCommand() argument266 fmq_response->set_success(false); in ProcessFmqCommand()268 (this->*(iterator->second))(fmq_request, fmq_response); in ProcessFmqCommand()283 FmqResponseMessage fmq_response; in RegisterFmq() local290 ProcessFmqCommand(fmq_request, &fmq_response); in RegisterFmq()291 return fmq_response.queue_id(); in RegisterFmq()297 FmqResponseMessage fmq_response; in GetQueueDescAddress() local304 ProcessFmqCommand(fmq_request, &fmq_response); in GetQueueDescAddress()305 bool success = fmq_response.success(); in GetQueueDescAddress()306 *result = fmq_response.sizet_return_val(); in GetQueueDescAddress()[all …]
144 FmqResponseMessage* fmq_response);191 FmqResponseMessage* fmq_response);200 FmqResponseMessage* fmq_response);234 bool FmqCpp2Proto(FmqResponseMessage* fmq_response, const string& data_type,
148 optional FmqResponseMessage fmq_response = 3001; field
184 optional FmqResponseMessage fmq_response = 3001; field