Skip to content

Instantly share code, notes, and snippets.

@openstacker
Created October 16, 2016 21:56
Show Gist options
  • Save openstacker/7a62799ade0523198da8ee90ba2c6a7b to your computer and use it in GitHub Desktop.
Save openstacker/7a62799ade0523198da8ee90ba2c6a7b to your computer and use it in GitHub Desktop.
oslo_messaging producer
#!/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:passw0rd@127.0.0.1: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'})
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment