<div style="line-height:1.7;color:#000000;font-size:14px;font-family:Arial"><div>Hello,</div><div>     In our envirment, we find, the oslo_messaging can cause message to send twice in chance.</div><div>     i find when we send a message that needs reply. oslo_messaging will get a reply queue first.</div><div><div>    def _get_reply_q(self):</div><div>        with self._reply_q_lock:</div><div>            if self._reply_q is not None:</div><div>                return self._reply_q</div><div><br></div><div>            reply_q = 'reply_' + uuid.uuid4().hex</div><div><br></div><div>            conn = self._get_connection(rpc_amqp.PURPOSE_LISTEN)</div><div><br></div><div>            self._waiter = ReplyWaiter(reply_q, conn,</div><div>                                       self._allowed_remote_exmods)</div><div><br></div><div>            self._reply_q = reply_q</div><div>            self._reply_q_conn = conn</div><div><br></div><div>        return self._reply_q</div></div><div>  </div><div>     We do not make the reply queue every time when we send a message.</div><div>     But when we send successfully, but the conneciton for reply is socket close. The client will wait for timeout for first message. </div><div>     Then the message will be send again to consumers to retry.</div><div><br></div><div>   </div><div><br></div><div>    </div><br><br><br><br><div style="position:relative;zoom:1">--<br><div>Best</div><div>    Li Tianqing</div><div style="clear:both"></div></div></div><br><br><span title="neteasefooter"><span id="netease_mail_footer"></span></span>