'Allows an extension to receive notifications of updates made to
items of interest.'

def _register_rpc_consumers(self, connection):

    endpoints = [resources_rpc.ResourcesPushRpcCallback()]
    for resource_type in self.SUPPORTED_RESOURCE_TYPES:
        registry.register(self._handle_notification, resource_type)
        topic = resources_rpc.resource_type_versioned_topic(resource_type)
        connection.create_consumer(topic, endpoints, fanout=True)
