@ Override public Collection < RegisteredService > load ( ) { LOGGER . trace ( "Loading services from [{}]" , serviceRegistry . getName ( ) ) ; this . services = this . serviceRegistry . load ( ) . stream ( ) . collect ( Collectors . toConcurrentMap ( r -> { LOGGER . debug ( "Adding registered service [{}]" , r . getServiceId ( ) ) ; return r . getId ( ) ; } , Function . identity ( ) , ( r , s ) -> s == null ? r : s ) ) ; loadInternal ( ) ; publishEvent ( new CasRegisteredServicesLoadedEvent ( this , getAllServices ( ) ) ) ; evaluateExpiredServiceDefinitions ( ) ; LOGGER . info ( "Loaded [{}] service(s) from [{}]." , this . services . size ( ) , this . serviceRegistry . getName ( ) ) ; return services . values ( ) ; }
Load services that are provided by the DAO .