X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=api%2Fescalator%2Fnotifier.py;h=60a39ea151239a259d3a9e0013981678141f9d22;hb=71d4f906c1a52f5dcba114ff8aa70148dafffd24;hp=1e6ea02f92884308801c3579433c7a32489affe6;hpb=c1783221873845d072b739c7ebd8d0a75fe00bb9;p=escalator.git diff --git a/api/escalator/notifier.py b/api/escalator/notifier.py index 1e6ea02..60a39ea 100644 --- a/api/escalator/notifier.py +++ b/api/escalator/notifier.py @@ -14,9 +14,9 @@ # License for the specific language governing permissions and limitations # under the License. -from oslo_config import cfg -from oslo_log import log as logging -import oslo_messaging +from oslo.config import cfg +from oslo.log import log as logging +import oslo.messaging from escalator import i18n @@ -44,7 +44,7 @@ LOG = logging.getLogger(__name__) def get_transport(): - return oslo_messaging.get_transport(CONF) + return oslo.messaging.get_transport(CONF) class Notifier(object): @@ -53,7 +53,7 @@ class Notifier(object): def __init__(self): publisher_id = CONF.default_publisher_id self._transport = get_transport() - self._notifier = oslo_messaging.Notifier(self._transport, + self._notifier = oslo.messaging.Notifier(self._transport, publisher_id=publisher_id) def warn(self, event_type, payload):