diff --git a/oslo/messaging/transport.py b/oslo/messaging/transport.py index 2a154c55f..5247be9eb 100644 --- a/oslo/messaging/transport.py +++ b/oslo/messaging/transport.py @@ -91,7 +91,7 @@ class Transport(object): if not target.topic: raise exceptions.InvalidTarget('A topic is required to send', target) - self._driver.send(target, ctxt, message, version) + self._driver.send_notification(target, ctxt, message, version) def _listen(self, target): if not (target.topic and target.server): diff --git a/tests/test_transport.py b/tests/test_transport.py index 62da912b5..dcf59555c 100644 --- a/tests/test_transport.py +++ b/tests/test_transport.py @@ -275,8 +275,8 @@ class TestTransportMethodArgs(test_utils.BaseTestCase): def test_send_notification(self): t = transport.Transport(_FakeDriver(cfg.CONF)) - self.mox.StubOutWithMock(t._driver, 'send') - t._driver.send(self._target, 'ctxt', 'message', 1.0) + self.mox.StubOutWithMock(t._driver, 'send_notification') + t._driver.send_notification(self._target, 'ctxt', 'message', 1.0) self.mox.ReplayAll() t._send_notification(self._target, 'ctxt', 'message', version=1.0)