jnpr/space/async.py
def pull_message(self):
        """
        Pull the next message from the hornet-q. It specifies an ``accept-wait``
        header with the value that was given as the ``wait_time`` argument in
        the constructor so that the pull waits for this many seconds on the
        server side waiting for a message.

        :returns:  If a message is pulled, it is parsed into a Python object
            and returned. If no message was pulled, returns ``None``.

        """

        headers = {"accept-wait": self.wait_time}
        response = self._rest_end_point.post(self.next_msg_url, headers, body=None)
        next_msg = response.headers["msg-consume-next"]
        if len(next_msg) > 0:
            self.next_msg_url = self._strip_uri(next_msg)

        if response.status_code == 200:
            xml = xmlutil.get_text_from_response(response)
            return xmlutil.xml2obj(xml)

        Pull the next message from the hornet-q. It specifies an ``accept-wait``
        header with the value that was given as the ``wait_time`` argument in
        the constructor so that the pull waits for this many seconds on the
        server side waiting for a message.

        :returns:  If a message is pulled, it is parsed into a Python object
            and returned. If no message was pulled, returns ``None``.

        
Pull the next message from the hornet-q.
Pull the next message from the hornet - q .
def pull_message(self):
        headers = {"accept-wait": self.wait_time}
        response = self._rest_end_point.post(self.next_msg_url, headers, body=None)
        next_msg = response.headers["msg-consume-next"]
        if len(next_msg) > 0:
            self.next_msg_url = self._strip_uri(next_msg)
        if response.status_code == 200:
            xml = xmlutil.get_text_from_response(response)
            return xmlutil.xml2obj(xml)
def pull_message ( self ) : headers = { "accept-wait" : self . wait_time } response = self . _rest_end_point . post ( self . next_msg_url , headers , body = None ) next_msg = response . headers [ "msg-consume-next" ] if len ( next_msg ) > 0 : self . next_msg_url = self . _strip_uri ( next_msg ) if response . status_code == 200 : xml = xmlutil . get_text_from_response ( response ) return xmlutil . xml2obj ( xml )
Pull the next message from the hornet-q.
Pull the next message from the hornet - q .
"""
        Pull the next message from the hornet-q. It specifies an ``accept-wait``
        header with the value that was given as the ``wait_time`` argument in
        the constructor so that the pull waits for this many seconds on the
        server side waiting for a message.

        :returns:  If a message is pulled, it is parsed into a Python object
            and returned. If no message was pulled, returns ``None``.

        """
If a message is pulled, it is parsed into a Python object
and returned. If no message was pulled, returns ``None``.
If a message is pulled it is parsed into a Python object and returned . If no message was pulled returns ` ` None ` ` .
self