def _rpc_response_callback(self, channel, method_frame, header_frame, body):
		"""
		Internal callback used by consume()

		Parameters
		----------
		channel: object
			Channel from which the callback originated
		method_frame: dict
			Information about the message
		header_frame: dict
			Headers of the message
		body: string
			Body of the message
		"""
		self.logger.debug("Received RPC response with correlation_id: {0}".format(header_frame.correlation_id))
		if header_frame.correlation_id in self.responses:
			self.responses[header_frame.correlation_id] = {
				"method_frame": method_frame,
				"header_frame": header_frame,
				"body": body
			}
		channel.basic_ack(method_frame.delivery_tag)
def _rpc_response_callback ( self , channel , method_frame , header_frame , body ) : self . logger . debug ( "Received RPC response with correlation_id: {0}" . format ( header_frame . correlation_id ) ) if header_frame . correlation_id in self . responses : self . responses [ header_frame . correlation_id ] = { "method_frame" : method_frame , "header_frame" : header_frame , "body" : body } channel . basic_ack ( method_frame . delivery_tag )
Internal callback used by consume()

		Parameters
		----------
		channel: object
			Channel from which the callback originated
		method_frame: dict
			Information about the message
		header_frame: dict
			Headers of the message
		body: string
			Body of the message