X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=api%2Fescalator%2Fnotifier.py;fp=api%2Fescalator%2Fnotifier.py;h=1e6ea02f92884308801c3579433c7a32489affe6;hb=74c631c6dae08d463f0d4c3953a1addcb187d090;hp=60a39ea151239a259d3a9e0013981678141f9d22;hpb=71d4f906c1a52f5dcba114ff8aa70148dafffd24;p=escalator.git diff --git a/api/escalator/notifier.py b/api/escalator/notifier.py index 60a39ea..1e6ea02 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):