service-registry/src/main/java/de/evoila/osb/service/registry/manager/ServiceBrokerManager.java
public void updateServiceBrokerCatalog(ServiceBroker broker, boolean forceUpdate) {
        if (broker == null || (!forceUpdate && cacheManager.exists(broker.getId()))) return;

        log.info((forceUpdate ? "Force" : "Soft" )+ " updating service catalog for " + broker.getLoggingNameString());
        try {
            ResponseWithHttpStatus<CatalogResponse> response = ServiceCatalogRequestService.getCatalog(broker);
            if (response != null && response.getBody() != null && response.getBody().getServices() != null) {
                log.debug("Caching received catalog for " + broker.getLoggingNameString());
                cacheManager.put(broker.getId(), response.getBody().getServices());
            } else {
                if (response != null)
                    throw new HttpClientErrorException(response.getStatus());
                throw new HttpClientErrorException(HttpStatus.NOT_FOUND);
            }
        } catch (HttpClientErrorException ex) {
            log.error("Updating service catalog failed with " + ex.getStatusCode() + " for " + broker.getLoggingNameString(), ex);
        } catch (ResourceAccessException ex) {
            log.error("Updating service catalog failed for " + broker.getLoggingNameString(), ex);
        }
    }
/**
     * Updates the service definition cache for a service broker. This involves a request to the service brokers catalog endpoint.
     * If the forceUpdate flag is not set, only a service broker that has no entry in the cache is updated.
     *
     * @param broker      service broker to update the cache for
     * @param forceUpdate flag to indicate a forced update
     */
Updates the service definition cache for a service broker. This involves a request to the service brokers catalog endpoint.
If the forceUpdate flag is not set, only a service broker that has no entry in the cache is updated.

@param broker      service broker to update the cache for
@param forceUpdate flag to indicate a forced update
Updates the service definition cache for a service broker . This involves a request to the service brokers catalog endpoint . If the forceUpdate flag is not set only a service broker that has no entry in the cache is updated . @param broker service broker to update the cache for @param forceUpdate flag to indicate a forced update
public void updateServiceBrokerCatalog(ServiceBroker broker, boolean forceUpdate) {
        if (broker == null || (!forceUpdate && cacheManager.exists(broker.getId()))) return;
        log.info((forceUpdate ? "Force" : "Soft" )+ " updating service catalog for " + broker.getLoggingNameString());
        try {
            ResponseWithHttpStatus<CatalogResponse> response = ServiceCatalogRequestService.getCatalog(broker);
            if (response != null && response.getBody() != null && response.getBody().getServices() != null) {
                log.debug("Caching received catalog for " + broker.getLoggingNameString());
                cacheManager.put(broker.getId(), response.getBody().getServices());
            } else {
                if (response != null)
                    throw new HttpClientErrorException(response.getStatus());
                throw new HttpClientErrorException(HttpStatus.NOT_FOUND);
            }
        } catch (HttpClientErrorException ex) {
            log.error("Updating service catalog failed with " + ex.getStatusCode() + " for " + broker.getLoggingNameString(), ex);
        } catch (ResourceAccessException ex) {
            log.error("Updating service catalog failed for " + broker.getLoggingNameString(), ex);
        }
    }
public void updateServiceBrokerCatalog ( ServiceBroker broker , boolean forceUpdate ) { if ( broker == null || ( ! forceUpdate && cacheManager . exists ( broker . getId ( ) ) ) ) return ; log . info ( ( forceUpdate ? "Force" : "Soft" ) + " updating service catalog for " + broker . getLoggingNameString ( ) ) ; try { ResponseWithHttpStatus < CatalogResponse > response = ServiceCatalogRequestService . getCatalog ( broker ) ; if ( response != null && response . getBody ( ) != null && response . getBody ( ) . getServices ( ) != null ) { log . debug ( "Caching received catalog for " + broker . getLoggingNameString ( ) ) ; cacheManager . put ( broker . getId ( ) , response . getBody ( ) . getServices ( ) ) ; } else { if ( response != null ) throw new HttpClientErrorException ( response . getStatus ( ) ) ; throw new HttpClientErrorException ( HttpStatus . NOT_FOUND ) ; } } catch ( HttpClientErrorException ex ) { log . error ( "Updating service catalog failed with " + ex . getStatusCode ( ) + " for " + broker . getLoggingNameString ( ) , ex ) ; } catch ( ResourceAccessException ex ) { log . error ( "Updating service catalog failed for " + broker . getLoggingNameString ( ) , ex ) ; } }
Updates the service definition cache for a service broker.
Updates the service definition cache for a service broker .