in nmr/osgi/src/main/java/org/apache/servicemix/nmr/osgi/ExecutorConfigurator.java [44:92]
public void update(Map properties) throws ConfigurationException {
if (executorFactory.getDefaultConfig() == null) {
executorFactory.setDefaultConfig(new ExecutorConfig(true, null));
}
Map<String, ExecutorConfig> configs = new HashMap<String, ExecutorConfig>();
if (properties != null) {
for (Object keyObject : properties.keySet()) {
String key = (String) keyObject;
if (key.endsWith(".corePoolSize")) {
getConfig(configs, key).setCorePoolSize(getInt(properties, key));
} else if (key.endsWith(".maximumPoolSize")) {
getConfig(configs, key).setMaximumPoolSize(getInt(properties, key));
} else if (key.endsWith(".keepAliveTime")) {
getConfig(configs, key).setKeepAliveTime(getLong(properties, key));
} else if (key.endsWith(".threadDaemon")) {
getConfig(configs, key).setThreadDaemon(getBool(properties, key));
} else if (key.endsWith(".threadPriority")) {
getConfig(configs, key).setThreadPriority(getInt(properties, key));
} else if (key.endsWith(".queueSize")) {
getConfig(configs, key).setQueueSize(getInt(properties, key));
} else if (key.endsWith(".shutdownDelay")) {
getConfig(configs, key).setShutdownDelay(getLong(properties, key));
} else if (key.endsWith(".allowCoreThreadTimeOut")) {
getConfig(configs, key).setAllowCoreThreadTimeOut(getBool(properties, key));
} else if (key.endsWith(".bypassIfSynchronous")) {
getConfig(configs, key).setBypassIfSynchronous(getBool(properties, key));
} else if (key.equals("corePoolSize")) {
executorFactory.getDefaultConfig().setCorePoolSize(getInt(properties, key));
} else if (key.equals("maximumPoolSize")) {
executorFactory.getDefaultConfig().setMaximumPoolSize(getInt(properties, key));
} else if (key.equals("keepAliveTime")) {
executorFactory.getDefaultConfig().setKeepAliveTime(getLong(properties, key));
} else if (key.equals("threadDaemon")) {
executorFactory.getDefaultConfig().setThreadDaemon(getBool(properties, key));
} else if (key.equals("threadPriority")) {
executorFactory.getDefaultConfig().setThreadPriority(getInt(properties, key));
} else if (key.equals("queueSize")) {
executorFactory.getDefaultConfig().setQueueSize(getInt(properties, key));
} else if (key.equals("shutdownDelay")) {
executorFactory.getDefaultConfig().setShutdownDelay(getLong(properties, key));
} else if (key.equals("allowCoreThreadTimeOut")) {
executorFactory.getDefaultConfig().setAllowCoreThreadTimeOut(getBool(properties, key));
} else if (key.equals("bypassIfSynchronous")) {
executorFactory.getDefaultConfig().setBypassIfSynchronous(getBool(properties, key));
}
}
}
executorFactory.setConfigs(configs);
}