| | |
| | | * |
| | | * |
| | | * Copyright 2008-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011 ForgeRock AS |
| | | * Portions Copyright 2011-2012 ForgeRock AS |
| | | */ |
| | | package org.opends.server.workflowelement.localbackend; |
| | | |
| | |
| | | |
| | | |
| | | // A string indicating the type of the workflow element. |
| | | private final String BACKEND_WORKFLOW_ELEMENT = "Backend"; |
| | | private static final String BACKEND_WORKFLOW_ELEMENT = "Backend"; |
| | | |
| | | |
| | | /** |
| | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | @Override |
| | | public boolean isConfigurationChangeAcceptable( |
| | | LocalBackendWorkflowElementCfg configuration, |
| | | List<Message> unacceptableReasons |
| | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | @Override |
| | | public ConfigChangeResult applyConfigurationChange( |
| | | LocalBackendWorkflowElementCfg configuration |
| | | ) |
| | |
| | | String workflowElementID, |
| | | Backend backend) |
| | | { |
| | | LocalBackendWorkflowElement localBackend = null; |
| | | |
| | | // If the requested workflow element does not exist then create one. |
| | | localBackend = registeredLocalBackends.get(workflowElementID); |
| | | LocalBackendWorkflowElement localBackend = |
| | | registeredLocalBackends.get(workflowElementID); |
| | | if (localBackend == null) |
| | | { |
| | | localBackend = new LocalBackendWorkflowElement(); |
| | |
| | | /** |
| | | * {@inheritDoc} |
| | | */ |
| | | @Override |
| | | public void execute(Operation operation) throws CanceledOperationException { |
| | | switch (operation.getOperationType()) |
| | | { |
| | |
| | | * operation |
| | | */ |
| | | @SuppressWarnings("unchecked") |
| | | public static final <O extends Operation,L> void |
| | | public static <O extends Operation,L> void |
| | | attachLocalOperation (O globalOperation, L currentLocalOperation) |
| | | { |
| | | List<?> existingAttachment = |
| | |
| | | PersistentSearch.CancellationCallback callback = |
| | | new PersistentSearch.CancellationCallback() |
| | | { |
| | | @Override |
| | | public void persistentSearchCancelled(PersistentSearch psearch) |
| | | { |
| | | persistentSearches.remove(psearch); |