@Test(expected = IllegalArgumentException.class) public void testCreateProcessorWithInvalidYieldDuration() { final String flowId = "1"; final String processGroupId = "child-level-2"; when(flowManager.getFlow(flowId)).thenReturn(Optional.of(flow)); when(extensionManagers.getExtensionManager(flow.getFlowMetadata().getAgentClass())) .thenReturn(Optional.of(extensionManager)); final VersionedProcessor requestProcessor = createVersionedProcessor(); requestProcessor.setYieldDuration("INVALID"); final FDProcessor resultProcessor = new FDProcessor(); resultProcessor.setComponentConfiguration(requestProcessor); resultProcessor.setComponentDefinition(new ProcessorDefinition()); when(extensionManager.createProcessor( requestProcessor.getType(), requestProcessor.getBundle())) .thenReturn(resultProcessor); processorService.create(flowId, processGroupId, requestProcessor); }
@Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; }
StandardFDProcessorService extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor> implements FDProcessorService { @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; } }
StandardFDProcessorService extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor> implements FDProcessorService { @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; } @Autowired  StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService); }
StandardFDProcessorService extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor> implements FDProcessorService { @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; } @Autowired  StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService); @Override FDComponentTypes getProcessorTypes(final String flowId); @Override FDPropertyDescriptor getPropertyDescriptor(final String flowId, final String processorId, final String propertyName); @Override FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig); @Override FDProcessor get(final String flowId, final String processorId); @Override FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig); @Override void delete(final String flowId, final String processorId); @Override ProcessorDefinition getComponentDefinition(final String agentClass, final VersionedProcessor componentConfig); }
StandardFDProcessorService extends BaseExtensionComponentService<VersionedProcessor, ProcessorDefinition, FDProcessor> implements FDProcessorService { @Override public FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig) { final FDFlow currentFlow = getFlowOrNotFound(flowId); validateRequestValues(requestComponentConfig); final String requestType = requestComponentConfig.getType(); final Bundle requestBundle = requestComponentConfig.getBundle(); final FDProcessor createdComponent = createExtensionComponent( currentFlow, processGroupId, requestType, requestComponentConfig, (em) -> em.createProcessor(requestType, requestBundle), VersionedProcessGroup::getProcessors, this::validate ); ComponentUtils.populateControllerServicePropertyDescriptors(currentFlow, processGroupId, createdComponent.getComponentDefinition()); return createdComponent; } @Autowired  StandardFDProcessorService(final FDFlowManager flowManager, final FDExtensionManagers extensionManagers, final ValidationService validationService); @Override FDComponentTypes getProcessorTypes(final String flowId); @Override FDPropertyDescriptor getPropertyDescriptor(final String flowId, final String processorId, final String propertyName); @Override FDProcessor create(final String flowId, final String processGroupId, final VersionedProcessor requestComponentConfig); @Override FDProcessor get(final String flowId, final String processorId); @Override FDProcessor update(final String flowId, final VersionedProcessor requestComponentConfig); @Override void delete(final String flowId, final String processorId); @Override ProcessorDefinition getComponentDefinition(final String agentClass, final VersionedProcessor componentConfig);  }