public void update()

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