diff --git a/neutron/agent/linux/openvswitch_firewall/firewall.py b/neutron/agent/linux/openvswitch_firewall/firewall.py
index ea2c7a79b25..d02f3ada90e 100644
--- a/neutron/agent/linux/openvswitch_firewall/firewall.py
+++ b/neutron/agent/linux/openvswitch_firewall/firewall.py
@@ -411,7 +411,7 @@ class OVSFirewallDriver(firewall.FirewallDriver):
             callbacks_resources.AGENT,
             callbacks_events.OVS_RESTARTED)
 
-    def _init_firewall_callback(self, resource, event, trigger, **kwargs):
+    def _init_firewall_callback(self, resource, event, trigger, payload=None):
         LOG.info("Reinitialize Openvswitch firewall after OVS restart.")
         self._initialize_firewall()
 
diff --git a/neutron/plugins/ml2/drivers/openvswitch/agent/ovs_neutron_agent.py b/neutron/plugins/ml2/drivers/openvswitch/agent/ovs_neutron_agent.py
index 5fc12f552b9..5b854903567 100644
--- a/neutron/plugins/ml2/drivers/openvswitch/agent/ovs_neutron_agent.py
+++ b/neutron/plugins/ml2/drivers/openvswitch/agent/ovs_neutron_agent.py
@@ -2127,10 +2127,10 @@ class OVSNeutronAgent(l2population_rpc.L2populationRpcCallBackTunnelMixin,
             self.dvr_agent.reset_dvr_parameters()
             self.dvr_agent.setup_dvr_flows()
         # notify that OVS has restarted
-        registry.notify(
+        registry.publish(
             callback_resources.AGENT,
             callback_events.OVS_RESTARTED,
-            self)
+            self, payload=None)
         # restart the polling manager so that it will signal as added
         # all the current ports
         # REVISIT (rossella_s) Define a method "reset" in
diff --git a/neutron/tests/functional/agent/test_l2_ovs_agent.py b/neutron/tests/functional/agent/test_l2_ovs_agent.py
index 4c1d923f9fa..02e3224950c 100644
--- a/neutron/tests/functional/agent/test_l2_ovs_agent.py
+++ b/neutron/tests/functional/agent/test_l2_ovs_agent.py
@@ -341,7 +341,7 @@ class TestOVSAgent(base.OVSAgentTestFramework):
 
         callback.assert_called_with(resources.AGENT,
                                     events.OVS_RESTARTED,
-                                    mock.ANY)
+                                    mock.ANY, payload=None)
 
 
 class TestOVSAgentExtensionConfig(base.OVSAgentTestFramework):