def notify_event_callbacks(service, resource_type, operation, payload):
 if (operation in _SUBSCRIBERS):
  if (resource_type in _SUBSCRIBERS[operation]):
   for cb in _SUBSCRIBERS[operation][resource_type]:
    subst_dict = {'cb_name': cb.__name__, 'service': service, 'resource_type': resource_type, 'operation': operation, 'payload': payload}
    LOG.debug('Invoking callback %(cb_name)s for event %(service)s %(resource_type)s %(operation)s for %(payload)s', subst_dict)
    cb(service, resource_type, operation, payload)

def notify_event_callbacks ( service , resource_type , operation , payload ) : if ( operation in _SUBSCRIBERS ) : if ( resource_type in _SUBSCRIBERS [ operation ] ) : for cb in _SUBSCRIBERS [ operation ] [ resource_type ] : subst_dict = { 'cb_name' : cb . __name__ , 'service' : service , 'resource_type' : resource_type , 'operation' : operation , 'payload' : payload } LOG . debug ( 'Invoking callback %(cb_name)s for event %(service)s %(resource_type)s %(operation)s for %(payload)s' , subst_dict ) cb ( service , resource_type , operation , payload )
send a notification to registered extensions .