)]}'
{"doc/source/driver-dev-guide.rst":[{"author":{"_account_id":9257,"name":"John Eckersberg","email":"jeckersb@redhat.com","username":"jeckersb"},"change_message_id":"4a0b730bfd035771fc1cc46ffb8872b517dc7613","unresolved":false,"context_lines":[{"line_number":19,"context_line":"**Note well:** The API described in this document is internal to the"},{"line_number":20,"context_line":"oslo.messaging library and therefore **private**.  Under no"},{"line_number":21,"context_line":"circumstances should this API be referenced by code external to the"},{"line_number":22,"context_line":"olso.messaging library."},{"line_number":23,"context_line":""},{"line_number":24,"context_line":"\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d\u003d"},{"line_number":25,"context_line":"Driver Interface"}],"source_content_type":"text/x-rst","patch_set":1,"id":"9a629dbe_c3eb75da","line":22,"updated":"2016-11-11 21:05:36.000000000","message":"olso-\u003eoslo","commit_id":"c745671c0d2e0f74fb3d4ef4d7086a9038e404ca"}],"oslo_messaging/_drivers/base.py":[{"author":{"_account_id":9257,"name":"John Eckersberg","email":"jeckersb@redhat.com","username":"jeckersb"},"change_message_id":"4a0b730bfd035771fc1cc46ffb8872b517dc7613","unresolved":false,"context_lines":[{"line_number":425,"context_line":"            operation to complete. Should this expire the :py:meth:`send` must"},{"line_number":426,"context_line":"            raise a :py:exc:`MessagingTimeout` exception"},{"line_number":427,"context_line":"        :type timeout: float"},{"line_number":428,"context_line":"        :param envelope: *Not Used?*"},{"line_number":429,"context_line":"        :param retry: maximum message send attempts permitted"},{"line_number":430,"context_line":"        :type retry: int"},{"line_number":431,"context_line":"        :returns: A reply message or None if no reply expected"}],"source_content_type":"text/x-python","patch_set":1,"id":"9a629dbe_5dcc9d88","line":428,"updated":"2016-11-11 21:05:36.000000000","message":"Only used in the amqp1 driver as it passes it along to marshal_request?","commit_id":"c745671c0d2e0f74fb3d4ef4d7086a9038e404ca"},{"author":{"_account_id":9257,"name":"John Eckersberg","email":"jeckersb@redhat.com","username":"jeckersb"},"change_message_id":"4a0b730bfd035771fc1cc46ffb8872b517dc7613","unresolved":false,"context_lines":[{"line_number":507,"context_line":"        * if the server attribute of the target is set then the driver must"},{"line_number":508,"context_line":"          also subscribe to messages sent to the exchange, topic, and server"},{"line_number":509,"context_line":""},{"line_number":510,"context_line":"        For example, given a topic with exchange \u0027my-exchange\u0027, topic"},{"line_number":511,"context_line":"        \u0027my-topic\u0027, and server \u0027my-server\u0027, the driver would create"},{"line_number":512,"context_line":"        subscriptions for:"},{"line_number":513,"context_line":""}],"source_content_type":"text/x-python","patch_set":1,"id":"9a629dbe_b9eceebb","line":510,"updated":"2016-11-11 21:05:36.000000000","message":"\"given a topic\" -\u003e \"given a target\" ?","commit_id":"c745671c0d2e0f74fb3d4ef4d7086a9038e404ca"},{"author":{"_account_id":9257,"name":"John Eckersberg","email":"jeckersb@redhat.com","username":"jeckersb"},"change_message_id":"4a0b730bfd035771fc1cc46ffb8872b517dc7613","unresolved":false,"context_lines":[{"line_number":512,"context_line":"        subscriptions for:"},{"line_number":513,"context_line":""},{"line_number":514,"context_line":"        * all messages sent to my-exchange and my-topic (including fanout)"},{"line_number":515,"context_line":"        * all messages sent to my-exchange, my-topic, and my server"},{"line_number":516,"context_line":""},{"line_number":517,"context_line":"        The driver must pass messages arriving from these subscriptions to the"},{"line_number":518,"context_line":"        listener. For :py:class:`PollStyleListener` the driver should trigger"}],"source_content_type":"text/x-python","patch_set":1,"id":"9a629dbe_190b1a7e","line":515,"updated":"2016-11-11 21:05:36.000000000","message":"\"my server\" -\u003e \"my-server\"","commit_id":"c745671c0d2e0f74fb3d4ef4d7086a9038e404ca"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"1cc6eaed59521ecdd65cf6a351c204c1ad23240f","unresolved":false,"context_lines":[{"line_number":94,"context_line":"        self.ctxt \u003d ctxt"},{"line_number":95,"context_line":"        self.message \u003d message"},{"line_number":96,"context_line":""},{"line_number":97,"context_line":"    def acknowledge(self):"},{"line_number":98,"context_line":"        \"\"\"Called by the server to acknowledge receipt of the message. When"},{"line_number":99,"context_line":"        this is called the driver must notify the backend of the"},{"line_number":100,"context_line":"        acknowledgment. This call should block at least until the driver has"}],"source_content_type":"text/x-python","patch_set":2,"id":"7a77a97e_441368b8","line":97,"updated":"2016-11-16 20:05:23.000000000","message":"Would it be helpful to add context for implementors that for RPC for RPC, acknowledge is prior to dispatch operation and for Notification it is post-dispatch (e.g. to enable requeue)","commit_id":"13c4d849c1760946502d63f45088af1dabd45d36"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"1cc6eaed59521ecdd65cf6a351c204c1ad23240f","unresolved":false,"context_lines":[{"line_number":108,"context_line":"        \"\"\""},{"line_number":109,"context_line":""},{"line_number":110,"context_line":"    @abc.abstractmethod"},{"line_number":111,"context_line":"    def requeue(self):"},{"line_number":112,"context_line":"        \"\"\"Called by the server to return the message to the backend so it may"},{"line_number":113,"context_line":"        be made available for consumption by another server.  This call should"},{"line_number":114,"context_line":"        block at least until the driver has processed the requeue request"}],"source_content_type":"text/x-python","patch_set":2,"id":"7a77a97e_e422b400","line":111,"updated":"2016-11-16 20:05:23.000000000","message":"Would it be noteworthy that requeue is intended for Notification only (following dispatch)?","commit_id":"13c4d849c1760946502d63f45088af1dabd45d36"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"1cc6eaed59521ecdd65cf6a351c204c1ad23240f","unresolved":false,"context_lines":[{"line_number":443,"context_line":"        requires a messaging backend that has the ability to store messages"},{"line_number":444,"context_line":"        until a consumer is present."},{"line_number":445,"context_line":""},{"line_number":446,"context_line":"        Therefore this method must block at least until the backend accepts"},{"line_number":447,"context_line":"        ownership of the message.  This method does not guarantee that the"},{"line_number":448,"context_line":"        message has or will be processed by the intended recipient."},{"line_number":449,"context_line":""}],"source_content_type":"text/x-python","patch_set":2,"id":"7a77a97e_4a2d3145","line":446,"updated":"2016-11-16 20:05:23.000000000","message":"Can \"accepts ownership\" be equated to message acknowledge by next hop of store and forward path?","commit_id":"13c4d849c1760946502d63f45088af1dabd45d36"},{"author":{"_account_id":20523,"name":"Andy Smith","email":"ansmith@redhat.com","username":"ajssmith"},"change_message_id":"1cc6eaed59521ecdd65cf6a351c204c1ad23240f","unresolved":false,"context_lines":[{"line_number":520,"context_line":"        the callback with the incoming messages."},{"line_number":521,"context_line":""},{"line_number":522,"context_line":"        This method only blocks long enough to establish the subscription(s)"},{"line_number":523,"context_line":"        and construct the listener.  In the case of failover, the driver must"},{"line_number":524,"context_line":"        restore the subscription(s). Subscriptions should remain active until"},{"line_number":525,"context_line":"        the listener is stopped."},{"line_number":526,"context_line":""}],"source_content_type":"text/x-python","patch_set":2,"id":"7a77a97e_df690527","line":523,"updated":"2016-11-16 20:05:23.000000000","message":"What are the failure \u0027types\u0027 for the failover case?","commit_id":"13c4d849c1760946502d63f45088af1dabd45d36"}]}