oslo_messaging producer

gistfile1.txt

#!/usr/bin/env python

# coding: utf-8

from oslo_config import cfg
import oslo_messaging
import logging

logging.basicConfig()
log = logging.getLogger()

log.addHandler(logging.StreamHandler())
log.setLevel(logging.INFO)

transport_url = 'rabbit://stackrabbit:[email protected]:5672/'
transport = oslo_messaging.get_transport(cfg.CONF, transport_url)

driver = 'messaging'

notifier = oslo_messaging.Notifier(transport, driver=driver, publisher_id='fake_publisher', topic='alarm.all')

notifier.info({'some': 'context'}, 'just.testing', {'heavy': 'payload'})