protected void update()

in src/main/java/org/apache/sling/event/impl/jobs/config/MainQueueConfiguration.java [104:175]


    protected void update(final Config config) {
        logger.debug("properties for queue {}: {}", MAIN_QUEUE_NAME, config);
        this.mainConfiguration = InternalQueueConfiguration.fromConfiguration(
                Collections.singletonMap(Constants.SERVICE_PID, (Object)"org.apache.sling.event.impl.jobs.DefaultJobManager"),
                new InternalQueueConfiguration.Config() {

            @Override
            public Class<? extends Annotation> annotationType() {
                return InternalQueueConfiguration.Config.class;
            }

            @Override
            public int service_ranking() {
                return 0;
            }

            @Override
            public String queue_type() {
                return InternalQueueConfiguration.Type.UNORDERED.name();
            }

            @Override
            public String[] queue_topics() {
                return new String[] {"*"};
            }

            @Override
            public int queue_threadPoolSize() {
                return 0;
            }

            @Override
            public long queue_retrydelay() {
                return config.queue_retrydelay();
            }

            @Override
            public int queue_retries() {
                return config.queue_retries();
            }

            @Override
            public String queue_priority() {
                return config.queue_priority();
            }

            @Override
            public boolean queue_preferRunOnCreationInstance() {
                return false;
            }

            @Override
            public String queue_name() {
                return MAIN_QUEUE_NAME;
            }

            @Override
            public double queue_maxparallel() {
                return config.queue_maxparallel();
            }

            @Override
            public boolean queue_keepJobs() {
                return false;
            }

            @Override
            public String webconsole_configurationFactory_nameHint() {
                return "Queue: {" + ConfigurationConstants.PROP_NAME + "}";
            }
        });
    }