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 + "}";
}
});
}