@Test(expected = IllegalArgumentException.class) public void testUpdateWithInvalidYieldDuration() { final String flowId = flow.getFlowMetadata().getIdentifier(); when(flowManager.getFlow(flowId)).thenReturn(Optional.of(flow)); final VersionedRemoteProcessGroup requestConfig = new VersionedRemoteProcessGroup(); requestConfig.setIdentifier(remoteProcessGroup.getIdentifier()); requestConfig.setYieldDuration("INVALID"); service.update(flowId, requestConfig); }
@Override public FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig) { validateRequestValues(requestComponentConfig); return updateComponent(flowId, requestComponentConfig, VersionedProcessGroup::getRemoteProcessGroups, null); }
StandardFDRemoteProcessGroupService extends BaseComponentService<VersionedRemoteProcessGroup,FDRemoteProcessGroup> implements FDRemoteProcessGroupService { @Override public FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig) { validateRequestValues(requestComponentConfig); return updateComponent(flowId, requestComponentConfig, VersionedProcessGroup::getRemoteProcessGroups, null); } }
StandardFDRemoteProcessGroupService extends BaseComponentService<VersionedRemoteProcessGroup,FDRemoteProcessGroup> implements FDRemoteProcessGroupService { @Override public FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig) { validateRequestValues(requestComponentConfig); return updateComponent(flowId, requestComponentConfig, VersionedProcessGroup::getRemoteProcessGroups, null); } StandardFDRemoteProcessGroupService(final FDFlowManager flowManager, final ValidationService validationService); }
StandardFDRemoteProcessGroupService extends BaseComponentService<VersionedRemoteProcessGroup,FDRemoteProcessGroup> implements FDRemoteProcessGroupService { @Override public FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig) { validateRequestValues(requestComponentConfig); return updateComponent(flowId, requestComponentConfig, VersionedProcessGroup::getRemoteProcessGroups, null); } StandardFDRemoteProcessGroupService(final FDFlowManager flowManager, final ValidationService validationService); @Override FDRemoteProcessGroup create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig); @Override FDRemoteProcessGroup get(final String flowId, final String componentId); @Override FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig); @Override void delete(final String flowId, final String componentId); }
StandardFDRemoteProcessGroupService extends BaseComponentService<VersionedRemoteProcessGroup,FDRemoteProcessGroup> implements FDRemoteProcessGroupService { @Override public FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig) { validateRequestValues(requestComponentConfig); return updateComponent(flowId, requestComponentConfig, VersionedProcessGroup::getRemoteProcessGroups, null); } StandardFDRemoteProcessGroupService(final FDFlowManager flowManager, final ValidationService validationService); @Override FDRemoteProcessGroup create(final String flowId, final String processGroupId, final VersionedRemoteProcessGroup requestComponentConfig); @Override FDRemoteProcessGroup get(final String flowId, final String componentId); @Override FDRemoteProcessGroup update(final String flowId, final VersionedRemoteProcessGroup requestComponentConfig); @Override void delete(final String flowId, final String componentId);  }