def METHOD_NAME(channel, method, properties, body):
    response = self._make_response(method, body)
    try:
        response_body = json.dumps(response)
    except Exception as e:
        response_body = json.dumps(self._error_response(e, "Response serialization error"))
    if not properties.reply_to:
        logging.error(f"No reply_to in message on exchange {self.exchange}, queue {self.name}")
        return
    channel.basic_publish(
        exchange=self.exchange,
        routing_key=properties.reply_to,
        properties=pika.BasicProperties(correlation_id=properties.correlation_id),
        body=response_body,
    )