OperationServiceImpl (Nuxeo ECM Projects 7.10-SNAPSHOT API)

java.lang.Object
- org.nuxeo.ecm.automation.core.impl.OperationServiceImpl

All Implemented Interfaces:

AutomationAdmin, AutomationService
```
public class OperationServiceImpl
extends Object
implements AutomationService, AutomationAdmin
```
The operation registry is thread safe and optimized for modifications at startup and lookups at runtime.

Author:

Bogdan Stefanescu

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

protected static class OperationServiceImpl.CacheKey

Nested Classes
Modifier and Type	Class and Description
`protected static class`	`OperationServiceImpl.CacheKey`

Field Summary

Fields
Modifier and Type	Field and Description
`protected AdapterKeyedRegistry`	`adapters` Adapter registry.
`protected AutomationFilterRegistry`	`automationFilterRegistry`
`protected ChainExceptionRegistry`	`chainExceptionRegistry`
`protected Map<OperationServiceImpl.CacheKey,org.nuxeo.ecm.automation.core.impl.CompiledChainImpl>`	`compiledChains`
`protected OperationTypeRegistry`	`operations`

Constructor Summary

Constructors
Constructor and Description

OperationServiceImpl()

Constructors
Constructor and Description
`OperationServiceImpl()`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`CompiledChain`	`compileChain(Class<?> inputType, OperationChain chain)` Builds the operation chain given a context.
`CompiledChain`	`compileChain(Class<?> inputType, OperationParameters... operations)` Same as previous but takes an array of operation parameters
`void`	`flushCompiledChains()` Flush compiled chains to handle hot-reload
`<T> T`	`getAdaptedValue(OperationContext ctx, Object toAdapt, Class<?> targetType)` Adapts an object to a target type if possible otherwise throws an exception.
`AutomationFilter`	`getAutomationFilter(String id)`
`AutomationFilter[]`	`getAutomationFilters()`
`protected CatchChainException`	`getCatchChainExceptionByPriority(CatchChainException catchChainException, CatchChainException catchChainExceptionItem)`
`ChainException`	`getChainException(String onChainId)`
`ChainException[]`	`getChainExceptions()`
`protected String`	`getChainExceptionToRun(OperationContext ctx, String operationTypeId, OperationException oe)`
`List<OperationDocumentation>`	`getDocumentation()` Generates a documentation model for all registered operations.
`OperationType`	`getOperation(String id)` Gets an operation type given its ID.
`OperationChain`	`getOperationChain(String id)` Gets a registered operation chain.
`List<OperationChain>`	`getOperationChains()` Gets a list of all registered chains
`OperationType[]`	`getOperations()` Gets all operation types that was registered.
`TypeAdapter`	`getTypeAdapter(Class<?> accept, Class<?> produce)` Gets a type adapter for the input type accept and the output type produce.
`static Class<?>`	`getTypeForPrimitive(Class<?> primitiveType)`
`boolean`	`hasChainException(String onChainId)`
`boolean`	`hasOperation(String id)`
`boolean`	`isTypeAdaptable(Class<?> typeToAdapt, Class<?> targetType)` Checks whether or not the given type is adaptable into the target type.
`void`	`putAutomationFilter(AutomationFilter automationFilter)`
`void`	`putChainException(ChainException exceptionChain)`
`void`	`putOperation(Class<?> type)` Registers an operation given its class.
`void`	`putOperation(Class<?> type, boolean replace)` Registers an operation given its class.
`void`	`putOperation(Class<?> type, boolean replace, String contributingComponent)` Registers an operation given its class.
`void`	`putOperation(Class<?> type, boolean replace, String contributingComponent, List<WidgetDefinition> widgetDefinitionList)`
`void`	`putOperation(OperationType op, boolean replace)` Registers an operation given it's type.
`void`	`putOperationChain(OperationChain chain)` Registers a parametrized operation chain.
`void`	`putOperationChain(OperationChain chain, boolean replace)` Registers a parametrized operation chain.
`void`	`putTypeAdapter(Class<?> accept, Class<?> produce, TypeAdapter adapter)` Registers a new type adapter that can adapt an instance of the accepted type into one of the produced type.
`void`	`removeAutomationFilter(AutomationFilter automationFilter)`
`void`	`removeExceptionChain(ChainException exceptionChain)`
`void`	`removeOperation(Class<?> key)` Removes an operation given its class.
`void`	`removeOperation(OperationType type)` Removes an operation given it's type.
`void`	`removeOperationChain(String id)` Removes a registered operation chain given its ID.
`void`	`removeTypeAdapter(Class<?> accept, Class<?> produce)` Removes a type adapter
`Object`	`run(OperationContext ctx, OperationChain chain)` Builds and runs the operation chain given a context.
`Object`	`run(OperationContext ctx, OperationType operationType, Map<String,Object> params)`
`Object`	`run(OperationContext ctx, String operationId)` Same as previous but for managed chains identified by an ID.
`Object`	`run(OperationContext ctx, String operationId, Map<String,Object> runtimeParameters)` TODO avoid creating a temporary chain and then compile it.
`Object`	`runInNewTx(OperationContext ctx, String chainId, Map chainParameters, Integer timeout, boolean rollbackGlobalOnError)` This running method execute operation process through a new transaction.
`static OperationParameters[]`	`toParams(String... ids)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - operations
```
protected final OperationTypeRegistry operations
```
  - chainExceptionRegistry
```
protected final ChainExceptionRegistry chainExceptionRegistry
```
  - automationFilterRegistry
```
protected final AutomationFilterRegistry automationFilterRegistry
```
  - compiledChains
```
protected Map<OperationServiceImpl.CacheKey,org.nuxeo.ecm.automation.core.impl.CompiledChainImpl> compiledChains
```
  - adapters
```
protected AdapterKeyedRegistry adapters
```
    Adapter registry.
- Constructor Detail
  - OperationServiceImpl
```
public OperationServiceImpl()
```
- Method Detail
  - run
```
public Object run(OperationContext ctx,
                  String operationId)
           throws OperationException
```
    Description copied from interface: AutomationService
    
    Same as previous but for managed chains identified by an ID. For managed chains always use this method since the compiled chain is cached and run will be faster
    
    Specified by:
    
    run in interface AutomationService
    
    Throws:
    
    OperationException
  - run
```
public Object run(OperationContext ctx,
                  OperationChain chain)
           throws OperationException
```
    Description copied from interface: AutomationService
    
    Builds and runs the operation chain given a context. If the context input object or the chain cannot be resolved (no path can be found through all the operation in the chain) then InvalidChainException is thrown.
    
    Specified by:
    
    run in interface AutomationService
    
    Throws:
    
    OperationException
  - run
```
public Object run(OperationContext ctx,
                  String operationId,
                  Map<String,Object> runtimeParameters)
           throws OperationException
```
    TODO avoid creating a temporary chain and then compile it. try to find a way to execute the single operation without compiling it. (for optimization)
    
    Specified by:
    
    run in interface AutomationService
    
    Throws:
    
    OperationException
  - runInNewTx
```
public Object runInNewTx(OperationContext ctx,
                         String chainId,
                         Map chainParameters,
                         Integer timeout,
                         boolean rollbackGlobalOnError)
                  throws OperationException
```
    This running method execute operation process through a new transaction.
    
    Specified by:
    
    runInNewTx in interface AutomationService
    
    Parameters:
    
    ctx - the operation context.
    
    chainId - the chain Id.
    
    chainParameters - chain parameters.
    
    timeout - Transaction timeout.
    
    rollbackGlobalOnError - Rollback or not transaction after failing.
    
    Throws:
    
    OperationException
  - run
```
public Object run(OperationContext ctx,
                  OperationType operationType,
                  Map<String,Object> params)
           throws OperationException
```
    Parameters:
    
    ctx - the operation context.
    
    operationType - a chain or an operation.
    
    params - The chain parameters.
    
    Throws:
    
    OperationException
    
    Since:
    
    5.7.2
  - getChainExceptionToRun
```
protected String getChainExceptionToRun(OperationContext ctx,
                                        String operationTypeId,
                                        OperationException oe)
                                 throws OperationException
```
    Throws:
    
    OperationException
    
    Since:
    
    5.7.3 Fetch the right chain id to run when catching exception for given chain failure.
  - getCatchChainExceptionByPriority
```
protected CatchChainException getCatchChainExceptionByPriority(CatchChainException catchChainException,
                                                               CatchChainException catchChainExceptionItem)
```
    Since:
    
    5.7.3
  - toParams
```
public static OperationParameters[] toParams(String... ids)
```
  - putOperationChain
```
public void putOperationChain(OperationChain chain)
                       throws OperationException
```
    Description copied from interface: AutomationService
    
    Registers a parametrized operation chain. This chain can be executed later by calling run and passing the chain ID. If a chain having the same ID exists an exception is thrown
    
    Specified by:
    
    putOperationChain in interface AutomationService
    
    Throws:
    
    OperationException
  - putOperationChain
```
public void putOperationChain(OperationChain chain,
                              boolean replace)
                       throws OperationException
```
    Description copied from interface: AutomationService
    
    Registers a parametrized operation chain. This chain can be executed later by calling run and passing the chain ID. If the replace attribute is true then any chain already registered under the same id will be replaced otherwise an exception is thrown.
    
    Specified by:
    
    putOperationChain in interface AutomationService
    
    Throws:
    
    OperationException
  - removeOperationChain
```
public void removeOperationChain(String id)
```
    Description copied from interface: AutomationService
    
    Removes a registered operation chain given its ID. Do nothing if the chain was not registered.
    
    Specified by:
    
    removeOperationChain in interface AutomationService
  - getOperationChain
```
public OperationChain getOperationChain(String id)
                                 throws OperationNotFoundException
```
    Description copied from interface: AutomationService
    
    Gets a registered operation chain.
    
    Specified by:
    
    getOperationChain in interface AutomationService
    
    Throws:
    
    OperationNotFoundException
  - getOperationChains
```
public List<OperationChain> getOperationChains()
```
    Description copied from interface: AutomationService
    
    Gets a list of all registered chains
    
    Specified by:
    
    getOperationChains in interface AutomationService
    
    Returns:
    
    the list or an empty list if no registered chains exists
  - flushCompiledChains
```
public void flushCompiledChains()
```
    Description copied from interface: AutomationAdmin
    
    Flush compiled chains to handle hot-reload
    
    Specified by:
    
    flushCompiledChains in interface AutomationAdmin
  - putOperation
```
public void putOperation(Class<?> type)
                  throws OperationException
```
    Description copied from interface: AutomationService
    
    Registers an operation given its class. The operation class MUST be annotated using Operation annotation. If an operation having the same ID exists an exception will be thrown.
    
    Specified by:
    
    putOperation in interface AutomationService
    
    Throws:
    
    OperationException
  - putOperation
```
public void putOperation(Class<?> type,
                         boolean replace)
                  throws OperationException
```
    Description copied from interface: AutomationService
    
    Registers an operation given its class. The operation class MUST be annotated using Operation annotation. If the replace argument is true then any existing operation having the same ID will replaced with this one.
    
    Specified by:
    
    putOperation in interface AutomationService
    
    Throws:
    
    OperationException
  - putOperation
```
public void putOperation(Class<?> type,
                         boolean replace,
                         String contributingComponent)
                  throws OperationException
```
    Description copied from interface: AutomationService
    
    Registers an operation given its class. The operation class MUST be annotated using Operation annotation. If the replace argument is true then any existing operation having the same ID will replaced with this one. Third argument represents the name of the component registring the operation
    
    Specified by:
    
    putOperation in interface AutomationService
    
    Throws:
    
    OperationException
  - putOperation
```
public void putOperation(Class<?> type,
                         boolean replace,
                         String contributingComponent,
                         List<WidgetDefinition> widgetDefinitionList)
                  throws OperationException
```
    Specified by:
    
    putOperation in interface AutomationService
    
    Throws:
    
    OperationException
  - putOperation
```
public void putOperation(OperationType op,
                         boolean replace)
                  throws OperationException
```
    Description copied from interface: AutomationService
    
    Registers an operation given it's type.
    
    Specified by:
    
    putOperation in interface AutomationService
    
    Throws:
    
    OperationException
  - removeOperation
```
public void removeOperation(Class<?> key)
```
    Description copied from interface: AutomationService
    
    Removes an operation given its class. If the operation was not registered does nothing.
    
    Specified by:
    
    removeOperation in interface AutomationService
  - removeOperation
```
public void removeOperation(OperationType type)
```
    Description copied from interface: AutomationService
    
    Removes an operation given it's type. If the operation was not registered does nothing.
    
    Specified by:
    
    removeOperation in interface AutomationService
  - getOperations
```
public OperationType[] getOperations()
```
    Description copied from interface: AutomationService
    
    Gets all operation types that was registered.
    
    Specified by:
    
    getOperations in interface AutomationService
  - getOperation
```
public OperationType getOperation(String id)
                           throws OperationNotFoundException
```
    Description copied from interface: AutomationService
    
    Gets an operation type given its ID. Throws an exception if the operation is not found.
    
    Specified by:
    
    getOperation in interface AutomationService
    
    Throws:
    
    OperationNotFoundException
  - hasOperation
```
public boolean hasOperation(String id)
```
    Specified by:
    
    hasOperation in interface AutomationService
    
    Parameters:
    
    id - operation ID.
    
    Returns:
    
    true if operation registry contains the given operation.
    
    Since:
    
    5.7.2
  - compileChain
```
public CompiledChain compileChain(Class<?> inputType,
                                  OperationChain chain)
                           throws OperationException
```
    Description copied from interface: AutomationService
    
    Builds the operation chain given a context. If the context input object or the chain cannot be resolved (no path can be found through all the operation in the chain) then InvalidChainException is thrown. The returned object can be used to run the chain.
    
    Specified by:
    
    compileChain in interface AutomationService
    
    Throws:
    
    OperationException
  - compileChain
```
public CompiledChain compileChain(Class<?> inputType,
                                  OperationParameters... operations)
                           throws OperationException
```
    Description copied from interface: AutomationService
    
    Same as previous but takes an array of operation parameters
    
    Specified by:
    
    compileChain in interface AutomationService
    
    Throws:
    
    OperationException
  - putTypeAdapter
```
public void putTypeAdapter(Class<?> accept,
                           Class<?> produce,
                           TypeAdapter adapter)
```
    Description copied from interface: AutomationService
    
    Registers a new type adapter that can adapt an instance of the accepted type into one of the produced type.
    
    Specified by:
    
    putTypeAdapter in interface AutomationService
  - removeTypeAdapter
```
public void removeTypeAdapter(Class<?> accept,
                              Class<?> produce)
```
    Description copied from interface: AutomationService
    
    Removes a type adapter
    
    Specified by:
    
    removeTypeAdapter in interface AutomationService
  - getTypeAdapter
```
public TypeAdapter getTypeAdapter(Class<?> accept,
                                  Class<?> produce)
```
    Description copied from interface: AutomationService
    
    Gets a type adapter for the input type accept and the output type produce. Returns null if no adapter was registered for these types.
    
    Specified by:
    
    getTypeAdapter in interface AutomationService
  - isTypeAdaptable
```
public boolean isTypeAdaptable(Class<?> typeToAdapt,
                               Class<?> targetType)
```
    Description copied from interface: AutomationService
    
    Checks whether or not the given type is adaptable into the target type. An instance of an adaptable type can be converted into an instance of the target type.
    This is a shortcut to getTypeAdapter(typeToAdapt, targetType) != null
    
    Specified by:
    
    isTypeAdaptable in interface AutomationService
  - getAdaptedValue
```
public <T> T getAdaptedValue(OperationContext ctx,
                             Object toAdapt,
                             Class<?> targetType)
                      throws OperationException
```
    Description copied from interface: AutomationService
    
    Adapts an object to a target type if possible otherwise throws an exception. The method must be called in an operation execution with a valid operation context.
    
    Specified by:
    
    getAdaptedValue in interface AutomationService
    
    Throws:
    
    OperationException
  - getDocumentation
```
public List<OperationDocumentation> getDocumentation()
                                              throws OperationException
```
    Description copied from interface: AutomationService
    
    Generates a documentation model for all registered operations. The documentation model is generated from operation annotations and can be used in UI tools to describe operations. The returned list is sorted using operation ID. Optional method.
    
    Specified by:
    
    getDocumentation in interface AutomationService
    
    Throws:
    
    OperationException
  - getTypeForPrimitive
```
public static Class<?> getTypeForPrimitive(Class<?> primitiveType)
```
  - putChainException
```
public void putChainException(ChainException exceptionChain)
```
    Specified by:
    
    putChainException in interface AutomationService
    
    Since:
    
    5.7.3
  - removeExceptionChain
```
public void removeExceptionChain(ChainException exceptionChain)
```
    Specified by:
    
    removeExceptionChain in interface AutomationService
    
    Since:
    
    5.7.3
  - getChainExceptions
```
public ChainException[] getChainExceptions()
```
    Specified by:
    
    getChainExceptions in interface AutomationService
    
    Since:
    
    5.7.3
  - getChainException
```
public ChainException getChainException(String onChainId)
```
    Specified by:
    
    getChainException in interface AutomationService
    
    Since:
    
    5.7.3
  - hasChainException
```
public boolean hasChainException(String onChainId)
```
    Specified by:
    
    hasChainException in interface AutomationService
    
    Since:
    
    5.7.3
  - putAutomationFilter
```
public void putAutomationFilter(AutomationFilter automationFilter)
```
    Specified by:
    
    putAutomationFilter in interface AutomationService
    
    Since:
    
    5.7.3
  - removeAutomationFilter
```
public void removeAutomationFilter(AutomationFilter automationFilter)
```
    Specified by:
    
    removeAutomationFilter in interface AutomationService
    
    Since:
    
    5.7.3
  - getAutomationFilter
```
public AutomationFilter getAutomationFilter(String id)
```
    Specified by:
    
    getAutomationFilter in interface AutomationService
    
    Since:
    
    5.7.3
  - getAutomationFilters
```
public AutomationFilter[] getAutomationFilters()
```
    Specified by:
    
    getAutomationFilters in interface AutomationService
    
    Since:
    
    5.7.3

Class OperationServiceImpl

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

operations

chainExceptionRegistry

automationFilterRegistry

compiledChains

adapters

Constructor Detail

OperationServiceImpl

Method Detail

run

run

run

runInNewTx

run

getChainExceptionToRun

getCatchChainExceptionByPriority

toParams

putOperationChain

putOperationChain

removeOperationChain

getOperationChain

getOperationChains

flushCompiledChains

putOperation

putOperation

putOperation

putOperation

putOperation

removeOperation

removeOperation

getOperations

getOperation

hasOperation

compileChain

compileChain

putTypeAdapter

removeTypeAdapter

getTypeAdapter

isTypeAdaptable

getAdaptedValue

getDocumentation

getTypeForPrimitive

putChainException

removeExceptionChain

getChainExceptions

getChainException

hasChainException

putAutomationFilter

removeAutomationFilter

getAutomationFilter

getAutomationFilters