scheduler/src/main/java/com/cognitree/kronos/scheduler/ConfigurationService.java
/**
     * Poll, parse and process updates from the configured queue.
     */
Poll, parse and process updates from the configured queue.
Poll parse and process updates from the configured queue .
private void processUpdates() {
        final List<String> configUpdates = configurationConsumer.poll();
        for (String configUpdateAsString : configUpdates) {
            if (configUpdateAsString == null || configUpdateAsString.trim().isEmpty()) {
                logger.trace("processUpdates: quietly skipping over null/ empty config update...");
                continue;
            }
            try {
                final ConfigUpdate configUpdate = READER.readValue(configUpdateAsString.trim());
                processUpdate(configUpdate);
            } catch (IOException e) {
                logger.error("processUpdates: unable to parse the config update received: " + configUpdateAsString, e);
            } catch (UnsupportedOperationException | ServiceException | ValidationException | SchedulerException e) {
                logger.error("processUpdates: error occurred in processing the config update received: {}",
                        configUpdateAsString, e);
            }
        }
    }
private void processUpdates ( ) { final List < String > configUpdates = configurationConsumer . poll ( ) ; for ( String configUpdateAsString : configUpdates ) { if ( configUpdateAsString == null || configUpdateAsString . trim ( ) . isEmpty ( ) ) { logger . trace ( "processUpdates: quietly skipping over null/ empty config update..." ) ; continue ; } try { final ConfigUpdate configUpdate = READER . readValue ( configUpdateAsString . trim ( ) ) ; processUpdate ( configUpdate ) ; } catch ( IOException e ) { logger . error ( "processUpdates: unable to parse the config update received: " + configUpdateAsString , e ) ; } catch ( UnsupportedOperationException | ServiceException | ValidationException | SchedulerException e ) { logger . error ( "processUpdates: error occurred in processing the config update received: {}" , configUpdateAsString , e ) ; } } }
Poll, parse and process updates from the configured queue.
Poll parse and process updates from the configured queue .
// Do not throw the exception but continue to process other updates // Do not throw the exception but continue to process other updates