'RPC endpoint for notification messages
When another service sends a notification over the message
bus, this method receives it.'

def sample(self, messages):

    goods = []
    for sample in chain.from_iterable((m['payload'] for m in messages)):
        if publisher_utils.verify_signature(sample, self.secret):
            goods.append(sample)
        else:
            LOG.warning('notification    signature    invalid,    discarding:    %s', sample)
    try:
        self.dispatcher_manager.map_method(self.method, goods)
    except Exception:
        LOG.exception('Dispatcher    failed    to    handle    the    notification,    re-queuing    it.')
        return oslo_messaging.NotificationResult.REQUEUE
