<div dir="ltr">Hi All and Ihar,<div><br></div><div style>As part of blueprint oslo-messaging the neutron/openstack/common/rpc tree is removed. I was using impl_kombu module to process notification from keystone with this following code sample:</div>
<div style>...</div><div style><div><font face="courier new, monospace">from neutron.openstack.common.rpc import impl_kombu</font></div><div><font face="courier new, monospace">       try:<br></font></div></div><div style>
<div><font face="courier new, monospace">           conf = impl_kombu.cfg.CONF</font></div><div><font face="courier new, monospace">            topicname = self._topic_name</font></div><div><font face="courier new, monospace">            exchange = self._exchange_name</font></div>
<div><font face="courier new, monospace">            connection = impl_kombu.Connection(conf)</font></div><div><font face="courier new, monospace">            connection.declare_topic_consumer(topic,</font></div><div><font face="courier new, monospace">                                              self.callback, </font></div>
<div><font face="courier new, monospace">                                              topic, </font><span style="font-family:'courier new',monospace">exchange)</span></div><div><font face="courier new, monospace">            connection.consume()</font></div>
<div><font face="courier new, monospace">        except Exception:</font></div><div><font face="courier new, monospace">            connection.close()</font></div><div><br></div></div><div style><br></div><div style>Can you please let me what needs to be done to replace the above code and make it work with current neutron code?</div>
<div style><br></div><div style><br></div><div style>Thanks in advance,</div><div style>Nader.</div><div style><br></div><div style><br></div><div style><br></div></div>