oslo.messaging listener

gistfile1.txt

#!/usr/bin/env python

# coding: utf-8

from oslo_config import cfg
import oslo_messaging
import logging

import eventlet

eventlet.monkey_patch()

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

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

class NotificationHandler(object):
    def info(self, ctxt, publisher_id, event_type, payload, metadata):
        print payload
        log.info('INFO')

    def warn(self, ctxt, publisher_id, event_type, payload, metadata):
        print payload
        log.info('WARN')

    def error(self, ctxt, publisher_id, event_type, payload, metadata):
        print payload
        log.info('ERROR')

log.info('Configuring connection')
transport_url = 'rabbit://stackrabbit:passw0rd@127.0.0.1:5672/'
transport = oslo_messaging.get_transport(cfg.CONF, transport_url)

targets = [oslo_messaging.Target(topic='notifications')]
endpoints = [NotificationHandler()]

server = oslo_messaging.get_notification_listener(transport, targets, endpoints, allow_requeue=True, executor='eventlet')
log.info('Starting up server')
server.start()
log.info('Waiting for something')
server.wait()