Fix DHCP agent updates

The commit 7267d75fdd3f90af759d71e9490cd41d41ba6d98 added
a new listener. We need to do the same here.

Change-Id: I8424fa5e913972f741367162ef284a7aa106b73a
This commit is contained in:
Gary Kotton 2015-10-04 10:37:06 -07:00 committed by garyk
parent 0e5c1f4ac6
commit 8c8885e37f
2 changed files with 6 additions and 0 deletions

View File

@ -89,6 +89,9 @@ class DhcpMetadataAccess(object):
agents_db.AgentExtRpcCallback(),
metadata_rpc.MetadataRpcCallback()]
self.conn.create_consumer(self.topic, self.endpoints, fanout=False)
self.conn.create_consumer(topics.REPORTS,
[agents_db.AgentExtRpcCallback()],
fanout=False)
self.agent_notifiers[const.AGENT_TYPE_DHCP] = (
notifier or dhcp_rpc_agent_api.DhcpAgentNotifyAPI())
self.conn.consume_in_threads()

View File

@ -164,6 +164,9 @@ class NsxV3Plugin(addr_pair_db.AllowedAddressPairsMixin,
agents_db.AgentExtRpcCallback(),
metadata_rpc.MetadataRpcCallback()]
self.conn.create_consumer(self.topic, self.endpoints, fanout=False)
self.conn.create_consumer(topics.REPORTS,
[agents_db.AgentExtRpcCallback()],
fanout=False)
self.agent_notifiers[const.AGENT_TYPE_DHCP] = (
dhcp_rpc_agent_api.DhcpAgentNotifyAPI())
self.conn.consume_in_threads()