| | |
| | | // using that configuration. |
| | | WorkQueueCfgDefn definition = WorkQueueCfgDefn.getInstance(); |
| | | ClassPropertyDefinition propertyDefinition = |
| | | definition.getWorkQueueClassPropertyDefinition(); |
| | | definition.getJavaClassPropertyDefinition(); |
| | | Class<? extends WorkQueue> workQueueClass = |
| | | propertyDefinition.loadClass(workQueueConfig.getWorkQueueClass(), |
| | | propertyDefinition.loadClass(workQueueConfig.getJavaClass(), |
| | | WorkQueue.class); |
| | | |
| | | try |
| | |
| | | catch (Exception e) |
| | | { |
| | | Message message = ERR_CONFIG_WORK_QUEUE_INITIALIZATION_FAILED. |
| | | get(workQueueConfig.getWorkQueueClass(), |
| | | get(workQueueConfig.getJavaClass(), |
| | | String.valueOf(workQueueConfig.dn()), |
| | | stackTraceToSingleLineString(e)); |
| | | throw new InitializationException(message, e); |
| | |
| | | // If the work queue class has been changed, then we should warn the user |
| | | // that it won't take effect until the server is restarted. |
| | | WorkQueue workQueue = DirectoryServer.getWorkQueue(); |
| | | String workQueueClass = configuration.getWorkQueueClass(); |
| | | String workQueueClass = configuration.getJavaClass(); |
| | | if (! workQueueClass.equals(workQueue.getClass().getName())) |
| | | { |
| | | |