def reply(self, connection, reply, orig_req):
        """Send an asynchronous reply to an earlier request.

        Parameters
        ----------
        connection : ClientConnection object
            The client to send the reply to.
        reply : Message object
            The reply message to send.
        orig_req : Message object
            The request message being replied to. The reply message's
            id is overridden with the id from orig_req before the
            reply is sent.

        """
        if isinstance(connection, ClientRequestConnection):
            self._logger.warn(
                'Deprecation warning: do not use self.reply() '
                'within a reply handler context -- use req.reply(*msg_args)\n'
                'or req.reply_with_message(msg) Traceback:\n %s',
                "".join(traceback.format_stack()))
            # Get the underlying ClientConnection instance
            connection = connection.client_connection
        connection.reply(reply, orig_req)
def reply ( self , connection , reply , orig_req ) : if isinstance ( connection , ClientRequestConnection ) : self . _logger . warn ( 'Deprecation warning: do not use self.reply() ' 'within a reply handler context -- use req.reply(*msg_args)\n' 'or req.reply_with_message(msg) Traceback:\n %s' , "" . join ( traceback . format_stack ( ) ) ) connection = connection . client_connection connection . reply ( reply , orig_req )
Send an asynchronous reply to an earlier request.

        Parameters
        ----------
        connection : ClientConnection object
            The client to send the reply to.
        reply : Message object
            The reply message to send.
        orig_req : Message object
            The request message being replied to. The reply message's
            id is overridden with the id from orig_req before the
            reply is sent.