@Test(expected = IllegalArgumentException.class) public void testGetManifestProcessorWhenTypeDoesNotExist() { final org.apache.nifi.registry.flow.Bundle bundle = getRequestBundle(httpBundle); extensionManager.getProcessorDefinition("does-not-exist", bundle); }
@Override public ProcessorDefinition getProcessorDefinition(final String type, final Bundle bundle) { final ProcessorDefinition manifestProcessor = locateManifestProcessor(type, bundle); return copyManifestProcessor(manifestProcessor); }
StandardFDExtensionManager implements FDExtensionManager { @Override public ProcessorDefinition getProcessorDefinition(final String type, final Bundle bundle) { final ProcessorDefinition manifestProcessor = locateManifestProcessor(type, bundle); return copyManifestProcessor(manifestProcessor); } }
StandardFDExtensionManager implements FDExtensionManager { @Override public ProcessorDefinition getProcessorDefinition(final String type, final Bundle bundle) { final ProcessorDefinition manifestProcessor = locateManifestProcessor(type, bundle); return copyManifestProcessor(manifestProcessor); } StandardFDExtensionManager(final AgentManifest agentManifest); }
StandardFDExtensionManager implements FDExtensionManager { @Override public ProcessorDefinition getProcessorDefinition(final String type, final Bundle bundle) { final ProcessorDefinition manifestProcessor = locateManifestProcessor(type, bundle); return copyManifestProcessor(manifestProcessor); } StandardFDExtensionManager(final AgentManifest agentManifest); @Override Set<FDComponentType> getProcessorTypes(); @Override ProcessorDefinition getProcessorDefinition(final String type, final Bundle bundle); @Override FDProcessor createProcessor(final String type, final Bundle bundle); @Override Optional<PropertyDescriptor> getProcessorPropertyDescriptor(final String type, final Bundle bundle, final String propertyName); @Override PropertyDescriptor createDynamicProcessorPropertyDescriptor(final String type, final Bundle bundle, final String propertyName); @Override Set<FDComponentType> getControllerServiceTypes(); @Override ControllerServiceDefinition getControllerServiceDefinition(final String type, final Bundle bundle); @Override FDControllerService createControllerService(final String type, final Bundle bundle); @Override Optional<PropertyDescriptor> getControllerServicePropertyDescriptor(final String type, final Bundle bundle, final String propertyName); @Override PropertyDescriptor createDynamicControllerServicePropertyDescriptor(final String type, final Bundle bundle, final String propertyName); }
StandardFDExtensionManager implements FDExtensionManager { @Override public ProcessorDefinition getProcessorDefinition(final String type, final Bundle bundle) { final ProcessorDefinition manifestProcessor = locateManifestProcessor(type, bundle); return copyManifestProcessor(manifestProcessor); } StandardFDExtensionManager(final AgentManifest agentManifest); @Override Set<FDComponentType> getProcessorTypes(); @Override ProcessorDefinition getProcessorDefinition(final String type, final Bundle bundle); @Override FDProcessor createProcessor(final String type, final Bundle bundle); @Override Optional<PropertyDescriptor> getProcessorPropertyDescriptor(final String type, final Bundle bundle, final String propertyName); @Override PropertyDescriptor createDynamicProcessorPropertyDescriptor(final String type, final Bundle bundle, final String propertyName); @Override Set<FDComponentType> getControllerServiceTypes(); @Override ControllerServiceDefinition getControllerServiceDefinition(final String type, final Bundle bundle); @Override FDControllerService createControllerService(final String type, final Bundle bundle); @Override Optional<PropertyDescriptor> getControllerServicePropertyDescriptor(final String type, final Bundle bundle, final String propertyName); @Override PropertyDescriptor createDynamicControllerServicePropertyDescriptor(final String type, final Bundle bundle, final String propertyName);  }