def test_callbacks_registered(self):
    with mock.patch.object(callbacks_registry, 'subscribe') as subscribe:
        firewall = ovsfw.OVSFirewallDriver(mock.MagicMock())
        subscribe.assert_called_once_with(firewall._init_firewall_callback, callbacks_resources.AGENT, callbacks_events.OVS_RESTARTED)
def test_callbacks_registered(self):
    with mock.patch.object(callbacks_registry, 'subscribe') as subscribe:
        firewall = ovsfw.OVSFirewallDriver(mock.MagicMock())
        subscribe.assert_called_once_with(firewall._init_firewall_callback, callbacks_resources.AGENT, callbacks_events.OVS_RESTARTED)