Open Stack

Hello,
     In our envirment, we find, the oslo_messaging can cause message to send twice in chance.
     i find when we send a message that needs reply. oslo_messaging will get a reply queue first.
    def _get_reply_q(self):
        with self._reply_q_lock:
            if self._reply_q is not None:
                return self._reply_q


            reply_q = 'reply_' + uuid.uuid4().hex


            conn = self._get_connection(rpc_amqp.PURPOSE_LISTEN)


            self._waiter = ReplyWaiter(reply_q, conn,
                                       self._allowed_remote_exmods)


            self._reply_q = reply_q
            self._reply_q_conn = conn


        return self._reply_q
  
     We do not make the reply queue every time when we send a message.
     But when we send successfully, but the conneciton for reply is socket close. The client will wait for timeout for first message. 
     Then the message will be send again to consumers to retry.


   


    





--

Best
    Li Tianqing
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.openstack.org/pipermail/openstack-dev/attachments/20150604/ff3820a1/attachment.html>