public class StandardNiFiServiceFacade extends java.lang.Object implements NiFiServiceFacade
| Constructor and Description |
|---|
StandardNiFiServiceFacade() |
| Modifier and Type | Method and Description |
|---|---|
ActivateControllerServicesEntity |
activateControllerServices(NiFiUser user,
java.lang.String processGroupId,
ControllerServiceState state,
java.util.Map<java.lang.String,Revision> serviceRevisions)
Enables or disables the controller services with the given IDs & Revisions on behalf of the given user
|
ActivateControllerServicesEntity |
activateControllerServices(java.lang.String processGroupId,
ControllerServiceState state,
java.util.Map<java.lang.String,Revision> serviceRevisions)
Enables or disables the controller services with the given IDs & Revisions on behalf of the currently logged in user
|
void |
authorizeAccess(AuthorizeAccess authorizeAccess)
Authorizes access to the service facade.
|
void |
clearControllerServiceState(java.lang.String controllerServiceId)
Clears the state for the specified controller service.
|
void |
clearProcessorState(java.lang.String processorId)
Clears the state for the specified processor.
|
void |
clearReportingTaskState(java.lang.String reportingTaskId)
Clears the state for the specified reporting task.
|
FlowEntity |
copySnippet(java.lang.String groupId,
java.lang.String snippetId,
java.lang.Double originX,
java.lang.Double originY,
java.lang.String idGenerationSeed)
Creates a new snippet based off the existing snippet.
|
AccessPolicyEntity |
createAccessPolicy(Revision revision,
AccessPolicyDTO accessPolicyDTO)
Creates an access policy.
|
BulletinEntity |
createBulletin(BulletinDTO bulletinDTO,
java.lang.Boolean canRead)
Create a system bulletin
|
ConnectionEntity |
createConnection(Revision revision,
java.lang.String groupId,
ConnectionDTO connectionDTO)
Creates a new Relationship target.
|
ControllerServiceEntity |
createControllerService(Revision revision,
java.lang.String groupId,
ControllerServiceDTO controllerServiceDTO)
Creates a controller service.
|
DropRequestDTO |
createFlowFileDropRequest(java.lang.String connectionId,
java.lang.String dropRequestId)
Creates a new flow file drop request.
|
ListingRequestDTO |
createFlowFileListingRequest(java.lang.String connectionId,
java.lang.String listingRequestId)
Creates a new flow file listing request.
|
FunnelEntity |
createFunnel(Revision revision,
java.lang.String groupId,
FunnelDTO funnelDTO)
Creates a funnel.
|
PortEntity |
createInputPort(Revision revision,
java.lang.String groupId,
PortDTO inputPortDTO)
Creates a new input port.
|
LabelEntity |
createLabel(Revision revision,
java.lang.String groupId,
LabelDTO labelDTO)
Creates a label.
|
PortEntity |
createOutputPort(Revision revision,
java.lang.String groupId,
PortDTO outputPortDTO)
Creates a new output port.
|
ProcessGroupEntity |
createProcessGroup(Revision revision,
java.lang.String parentGroupId,
ProcessGroupDTO processGroupDTO)
Creates a new process group.
|
ProcessorEntity |
createProcessor(Revision revision,
java.lang.String groupId,
ProcessorDTO processorDTO)
Creates a new Processor.
|
RemoteProcessGroupEntity |
createRemoteProcessGroup(Revision revision,
java.lang.String groupId,
RemoteProcessGroupDTO remoteProcessGroupDTO)
Creates a new remote process group.
|
ReportingTaskEntity |
createReportingTask(Revision revision,
ReportingTaskDTO reportingTaskDTO)
Creates a reporting task.
|
SnippetEntity |
createSnippet(SnippetDTO snippetDTO)
Creates a new snippet.
|
TemplateDTO |
createTemplate(java.lang.String name,
java.lang.String description,
java.lang.String snippetId,
java.lang.String groupId,
java.util.Optional<java.lang.String> idGenerationSeed)
Creates a new Template based off the specified snippet.
|
FlowEntity |
createTemplateInstance(java.lang.String groupId,
java.lang.Double originX,
java.lang.Double originY,
java.lang.String templateEncodingVersion,
FlowSnippetDTO requestSnippet,
java.lang.String idGenerationSeed)
Instantiate the corresponding template.
|
UserEntity |
createUser(Revision revision,
UserDTO userDTO)
Creates a user.
|
UserGroupEntity |
createUserGroup(Revision revision,
UserGroupDTO userGroupDTO)
Creates a user group.
|
AccessPolicyEntity |
deleteAccessPolicy(Revision revision,
java.lang.String accessPolicyId)
Deletes the specified access policy.
|
void |
deleteActions(java.util.Date endDate)
Purges all actions up to the specified end date.
|
ConnectionEntity |
deleteConnection(Revision revision,
java.lang.String connectionId)
Deletes the specified relationship target.
|
ControllerServiceEntity |
deleteControllerService(Revision revision,
java.lang.String controllerServiceId)
Deletes the specified label.
|
DropRequestDTO |
deleteFlowFileDropRequest(java.lang.String connectionId,
java.lang.String dropRequestId)
Cancels/removes the specified flow file drop request.
|
ListingRequestDTO |
deleteFlowFileListingRequest(java.lang.String connectionId,
java.lang.String listingRequestId)
Deletes a new flow file listing request.
|
FunnelEntity |
deleteFunnel(Revision revision,
java.lang.String funnelId)
Deletes the specified funnel.
|
PortEntity |
deleteInputPort(Revision revision,
java.lang.String inputPortId)
Deletes the specified input port.
|
LabelEntity |
deleteLabel(Revision revision,
java.lang.String labelId)
Deletes the specified label.
|
void |
deleteLineage(java.lang.String lineageId)
Deletes the lineage with the specified id.
|
void |
deleteNode(java.lang.String nodeId)
Deletes the node.
|
PortEntity |
deleteOutputPort(Revision revision,
java.lang.String outputPortId)
Determines if the output port could be deleted.
|
ProcessGroupEntity |
deleteProcessGroup(Revision revision,
java.lang.String groupId)
Deletes the specified process group.
|
ProcessorEntity |
deleteProcessor(Revision revision,
java.lang.String processorId)
Deletes the specified processor.
|
void |
deleteProvenance(java.lang.String queryId)
Deletes provenance.
|
RemoteProcessGroupEntity |
deleteRemoteProcessGroup(Revision revision,
java.lang.String remoteProcessGroupId)
Deletes the specified remote process group.
|
ReportingTaskEntity |
deleteReportingTask(Revision revision,
java.lang.String reportingTaskId)
Deletes the specified reporting task.
|
SnippetEntity |
deleteSnippet(java.util.Set<Revision> revisions,
java.lang.String snippetId)
Removes the specified snippet.
|
void |
deleteTemplate(java.lang.String id)
Deletes the specified template.
|
UserEntity |
deleteUser(Revision revision,
java.lang.String userId)
Deletes the specified user.
|
UserGroupEntity |
deleteUserGroup(Revision revision,
java.lang.String userGroupId)
Deletes the specified user group.
|
TemplateDTO |
exportTemplate(java.lang.String id)
Gets the template, includes contents, with the specified id.
|
AccessPolicyEntity |
getAccessPolicy(RequestAction requestAction,
java.lang.String resource)
Gets the access policy for the specified action, resource type, and component id.
|
AccessPolicyEntity |
getAccessPolicy(java.lang.String accessPolicyId)
Gets the access policy with the specified ID.
|
ActionEntity |
getAction(java.lang.Integer actionId)
Returns the details for the specified action id.
|
HistoryDTO |
getActions(HistoryQueryDTO historyQueryDto)
Returns actions that meet the specified criteria.
|
java.util.Set<AffectedComponentDTO> |
getActiveComponentsAffectedByVariableRegistryUpdate(VariableRegistryDTO variableRegistryDto)
Determines which components are active and will be affected by updating the given Variable Registry.
|
BulletinBoardDTO |
getBulletinBoard(BulletinQueryDTO query) |
ClusterDTO |
getCluster() |
ComponentHistoryDTO |
getComponentHistory(java.lang.String componentId)
Gets the history for the specified property for the specified component.
|
java.util.Set<AffectedComponentEntity> |
getComponentsAffectedByVariableRegistryUpdate(VariableRegistryDTO variableRegistryDto)
Determines which components will be affected by updating the given Variable Registry.
|
ConnectionEntity |
getConnection(java.lang.String connectionId)
Gets the specified Connection transfer object.
|
java.util.Set<ConnectionEntity> |
getConnections(java.lang.String groupId)
Gets the Connection transfer objects for the specified source processor.
|
ConnectionStatusEntity |
getConnectionStatus(java.lang.String connectionId)
Gets the status of the specified connection.
|
StatusHistoryEntity |
getConnectionStatusHistory(java.lang.String connectionId)
Gets the status history of the specified connection.
|
DownloadableContent |
getContent(java.lang.Long eventId,
java.lang.String uri,
ContentDirection contentDirection)
Gets the content for the specified claim.
|
DownloadableContent |
getContent(java.lang.String connectionId,
java.lang.String flowFileUuid,
java.lang.String uri)
Gets the content for the specified flowfile in the specified connection.
|
ControllerBulletinsEntity |
getControllerBulletins()
Gets the controller level bulletins.
|
ControllerConfigurationEntity |
getControllerConfiguration()
Gets the configuration for this controller.
|
ControllerServiceEntity |
getControllerService(java.lang.String controllerServiceId)
Gets the specified controller service.
|
PropertyDescriptorDTO |
getControllerServicePropertyDescriptor(java.lang.String id,
java.lang.String property)
Get the descriptor for the specified property of the specified controller service.
|
ControllerServiceReferencingComponentsEntity |
getControllerServiceReferencingComponents(java.lang.String controllerServiceId)
Gets the references for specified controller service.
|
java.util.Set<ControllerServiceEntity> |
getControllerServices(java.lang.String groupId,
boolean includeAncestorGroups,
boolean includeDescendantGroups)
Gets all controller services that belong to the given group and its parent/ancestor groups
|
java.util.Set<ControllerServiceEntity> |
getControllerServices(java.lang.String groupId,
boolean includeAncestorGroups,
boolean includeDescendantGroups,
NiFiUser user)
Gets all controller services that belong to the given group and its parent/ancestor groups
|
ComponentStateDTO |
getControllerServiceState(java.lang.String controllerServiceId)
Gets the state for the specified controller service.
|
java.util.Set<DocumentedTypeDTO> |
getControllerServiceTypes(java.lang.String serviceType,
java.lang.String serviceBundleGroup,
java.lang.String serviceBundleArtifact,
java.lang.String serviceBundleVersion,
java.lang.String bundleGroup,
java.lang.String bundleArtifact,
java.lang.String type)
Returns the list of controller service types.
|
ControllerStatusDTO |
getControllerStatus()
Returns the controller status.
|
CountersDTO |
getCounters()
Returns the counters.
|
CurrentUserEntity |
getCurrentUser() |
FlowConfigurationEntity |
getFlowConfiguration()
Gets the configuration for the flow.
|
FlowFileDTO |
getFlowFile(java.lang.String connectionId,
java.lang.String flowFileUuid)
Gets the specified flowfile from the specified connection.
|
DropRequestDTO |
getFlowFileDropRequest(java.lang.String connectionId,
java.lang.String dropRequestId)
Gets the specified flow file drop request.
|
ListingRequestDTO |
getFlowFileListingRequest(java.lang.String connectionId,
java.lang.String listingRequestId)
Gets a new flow file listing request.
|
FunnelEntity |
getFunnel(java.lang.String funnelId)
Gets the specified funnel.
|
java.util.Set<FunnelEntity> |
getFunnels(java.lang.String groupId)
Gets all of the funnels.
|
PortEntity |
getInputPort(java.lang.String inputPortId)
Gets an input port.
|
java.util.Set<PortEntity> |
getInputPorts(java.lang.String groupId)
Gets all input ports in a given group.
|
PortStatusEntity |
getInputPortStatus(java.lang.String inputPortId)
Gets the input port status.
|
LabelEntity |
getLabel(java.lang.String labelId)
Gets the specified label.
|
java.util.Set<LabelEntity> |
getLabels(java.lang.String groupId)
Gets all of the labels.
|
LineageDTO |
getLineage(java.lang.String lineageId)
Gets the lineage with the specified id.
|
NodeDTO |
getNode(java.lang.String nodeId)
Returns the contents of the node.
|
java.lang.String |
getNodeId() |
PortEntity |
getOutputPort(java.lang.String outputPortId)
Gets an output port.
|
java.util.Set<PortEntity> |
getOutputPorts(java.lang.String groupId)
Gets all output ports in a given group.
|
PortStatusEntity |
getOutputPortStatus(java.lang.String outputPortId)
Gets the output port status.
|
ProcessGroupEntity |
getProcessGroup(java.lang.String groupId)
Returns the process group.
|
ProcessGroupFlowEntity |
getProcessGroupFlow(java.lang.String groupId)
Returns the flow.
|
java.util.Set<ProcessGroupEntity> |
getProcessGroups(java.lang.String parentGroupId)
Gets all process groups in the specified parent group.
|
ProcessGroupStatusEntity |
getProcessGroupStatus(java.lang.String groupId,
boolean recursive)
Returns the process group status.
|
StatusHistoryEntity |
getProcessGroupStatusHistory(java.lang.String groupId)
Gets the process group status history.
|
ProcessorEntity |
getProcessor(java.lang.String id)
Gets the Processor transfer object for the specified id.
|
PropertyDescriptorDTO |
getProcessorPropertyDescriptor(java.lang.String id,
java.lang.String property)
Get the descriptor for the specified property of the specified processor.
|
java.util.Set<ProcessorEntity> |
getProcessors(java.lang.String groupId,
boolean includeDescendants)
Gets all the Processor transfer objects for this controller.
|
ComponentStateDTO |
getProcessorState(java.lang.String processorId)
Gets the state for the specified processor.
|
ProcessorStatusEntity |
getProcessorStatus(java.lang.String id)
Gets the processor status.
|
StatusHistoryEntity |
getProcessorStatusHistory(java.lang.String id)
Gets the processor status history.
|
java.util.Set<DocumentedTypeDTO> |
getProcessorTypes(java.lang.String bundleGroup,
java.lang.String bundleArtifact,
java.lang.String type)
Returns the list of processor types.
|
ProvenanceDTO |
getProvenance(java.lang.String queryId,
java.lang.Boolean summarize,
java.lang.Boolean incrementalResults)
Retrieves provenance.
|
ProvenanceEventDTO |
getProvenanceEvent(java.lang.Long id)
Gets the provenance event with the specified id.
|
ProvenanceOptionsDTO |
getProvenanceSearchOptions()
Returns the available options for searching provenance.
|
RemoteProcessGroupEntity |
getRemoteProcessGroup(java.lang.String remoteProcessGroupId)
Gets a remote process group.
|
java.util.Set<RemoteProcessGroupEntity> |
getRemoteProcessGroups(java.lang.String groupId)
Gets all remote process groups in the a given parent group.
|
RemoteProcessGroupStatusEntity |
getRemoteProcessGroupStatus(java.lang.String id)
Gets the remote process group status.
|
StatusHistoryEntity |
getRemoteProcessGroupStatusHistory(java.lang.String id)
Gets the remote process group status history.
|
ReportingTaskEntity |
getReportingTask(java.lang.String reportingTaskId)
Gets the specified reporting task.
|
PropertyDescriptorDTO |
getReportingTaskPropertyDescriptor(java.lang.String id,
java.lang.String property)
Get the descriptor for the specified property of the specified reporting task.
|
java.util.Set<ReportingTaskEntity> |
getReportingTasks()
Gets all reporting tasks.
|
ComponentStateDTO |
getReportingTaskState(java.lang.String reportingTaskId)
Gets the state for the specified reporting task.
|
java.util.Set<DocumentedTypeDTO> |
getReportingTaskTypes(java.lang.String bundleGroup,
java.lang.String bundleArtifact,
java.lang.String type)
Returns the list of reporting task types.
|
java.util.List<ResourceDTO> |
getResources() |
java.util.Set<Revision> |
getRevisionsFromGroup(java.lang.String groupId,
java.util.function.Function<ProcessGroup,java.util.Set<java.lang.String>> getComponents)
Gets the current revisions for the components based on the specified function.
|
java.util.Set<Revision> |
getRevisionsFromSnippet(java.lang.String snippetId)
Gets the revisions from the specified snippet.
|
ControllerDTO |
getSiteToSiteDetails() |
SystemDiagnosticsDTO |
getSystemDiagnostics() |
TemplateDTO |
getTemplate(java.lang.String id)
Gets the template with the specified id.
|
java.util.Set<TemplateEntity> |
getTemplates()
Gets all templates.
|
UserEntity |
getUser(java.lang.String userId)
Gets the user with the specified ID.
|
UserGroupEntity |
getUserGroup(java.lang.String userGroupId)
Gets the user group with the specified ID.
|
java.util.Set<UserGroupEntity> |
getUserGroups()
Gets all user groups.
|
java.util.Set<UserEntity> |
getUsers()
Gets all the users.
|
VariableRegistryEntity |
getVariableRegistry(java.lang.String groupId,
boolean includeAncestorGroups)
Returns the Variable Registry for the Process Group with the given ID
|
java.util.Set<DocumentedTypeDTO> |
getWorkQueuePrioritizerTypes()
Returns the list of prioritizer types.
|
TemplateDTO |
importTemplate(TemplateDTO templateDTO,
java.lang.String groupId,
java.util.Optional<java.lang.String> idGenerationSeed)
Imports the specified Template.
|
boolean |
isClustered() |
VariableRegistryEntity |
populateAffectedComponents(VariableRegistryDTO variableRegistryDto)
Returns a Variable Registry that includes the variables in the given DTO but has the affected components populated
|
ScheduleComponentsEntity |
scheduleComponents(NiFiUser user,
java.lang.String processGroupId,
ScheduledState state,
java.util.Map<java.lang.String,Revision> componentRevisions)
Schedules all applicable components under the specified ProcessGroup on behalf of the given user.
|
ScheduleComponentsEntity |
scheduleComponents(java.lang.String processGroupId,
ScheduledState state,
java.util.Map<java.lang.String,Revision> componentRevisions)
Schedules all applicable components under the specified ProcessGroup on behalf of the currently logged in user.
|
SearchResultsDTO |
searchController(java.lang.String query)
Searches the controller for the specified query string.
|
void |
setAccessPolicyDAO(AccessPolicyDAO accessPolicyDAO) |
void |
setAuditService(AuditService auditService) |
void |
setAuthorizableLookup(AuthorizableLookup authorizableLookup) |
void |
setAuthorizer(Authorizer authorizer) |
void |
setBulletinRepository(BulletinRepository bulletinRepository) |
void |
setClusterCoordinator(ClusterCoordinator coordinator) |
void |
setConnectionDAO(ConnectionDAO connectionDAO) |
void |
setControllerFacade(ControllerFacade controllerFacade) |
void |
setControllerServiceDAO(ControllerServiceDAO controllerServiceDAO) |
void |
setDtoFactory(DtoFactory dtoFactory) |
void |
setEntityFactory(EntityFactory entityFactory) |
void |
setFunnelDAO(FunnelDAO funnelDAO) |
void |
setHeartbeatMonitor(HeartbeatMonitor heartbeatMonitor) |
void |
setInputPortDAO(PortDAO inputPortDAO) |
void |
setLabelDAO(LabelDAO labelDAO) |
void |
setLeaderElectionManager(LeaderElectionManager leaderElectionManager) |
void |
setOutputPortDAO(PortDAO outputPortDAO) |
void |
setProcessGroupDAO(ProcessGroupDAO processGroupDAO) |
void |
setProcessorDAO(ProcessorDAO processorDAO) |
void |
setProperties(NiFiProperties properties) |
void |
setRemoteProcessGroupDAO(RemoteProcessGroupDAO remoteProcessGroupDAO) |
void |
setReportingTaskDAO(ReportingTaskDAO reportingTaskDAO) |
void |
setRevisionManager(RevisionManager revisionManager) |
void |
setSnippetDAO(SnippetDAO snippetDAO) |
void |
setSnippetUtils(SnippetUtils snippetUtils) |
void |
setTemplateDAO(TemplateDAO templateDAO) |
void |
setUserDAO(UserDAO userDAO) |
void |
setUserGroupDAO(UserGroupDAO userGroupDAO) |
LineageDTO |
submitLineage(LineageDTO lineage)
Submits a lineage request.
|
ProvenanceDTO |
submitProvenance(ProvenanceDTO query)
Submits a provenance request.
|
ProvenanceEventDTO |
submitReplay(java.lang.Long eventId)
Submits a new replay request.
|
AccessPolicyEntity |
updateAccessPolicy(Revision revision,
AccessPolicyDTO accessPolicyDTO)
Updates the specified access policy.
|
ConnectionEntity |
updateConnection(Revision revision,
ConnectionDTO connectionDTO)
Updates the specified Relationship target.
|
ControllerConfigurationEntity |
updateControllerConfiguration(Revision revision,
ControllerConfigurationDTO controllerConfigurationDTO)
Updates the configuration for this controller.
|
ControllerServiceEntity |
updateControllerService(Revision revision,
ControllerServiceDTO controllerServiceDTO)
Updates the specified controller service.
|
ControllerServiceReferencingComponentsEntity |
updateControllerServiceReferencingComponents(java.util.Map<java.lang.String,Revision> referenceRevisions,
java.lang.String controllerServiceId,
ScheduledState scheduledState,
ControllerServiceState controllerServiceState)
Updates the referencing components for the specified controller service.
|
CounterDTO |
updateCounter(java.lang.String counterId)
Updates the specified counter by setting its value to 0.
|
FunnelEntity |
updateFunnel(Revision revision,
FunnelDTO funnelDTO)
Updates the specified funnel.
|
PortEntity |
updateInputPort(Revision revision,
PortDTO inputPortDTO)
Updates the specified input port.
|
LabelEntity |
updateLabel(Revision revision,
LabelDTO labelDTO)
Updates the specified label.
|
NodeDTO |
updateNode(NodeDTO nodeDTO)
Updates the contents of the node.
|
PortEntity |
updateOutputPort(Revision revision,
PortDTO outputPortDTO)
Updates the specified output port.
|
ProcessGroupEntity |
updateProcessGroup(Revision revision,
ProcessGroupDTO processGroupDTO)
Updates the specified process group.
|
ProcessorEntity |
updateProcessor(Revision revision,
ProcessorDTO processorDTO)
Updates the specified Processor.
|
RemoteProcessGroupEntity |
updateRemoteProcessGroup(Revision revision,
RemoteProcessGroupDTO remoteProcessGroupDTO)
Updates the specified remote process group.
|
RemoteProcessGroupPortEntity |
updateRemoteProcessGroupInputPort(Revision revision,
java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
Updates the specified remote process groups input port.
|
RemoteProcessGroupPortEntity |
updateRemoteProcessGroupOutputPort(Revision revision,
java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
Updates the specified remote process groups output port.
|
ReportingTaskEntity |
updateReportingTask(Revision revision,
ReportingTaskDTO reportingTaskDTO)
Updates the specified reporting task.
|
SnippetEntity |
updateSnippet(java.util.Set<Revision> revisions,
SnippetDTO snippetDto)
If group id is specified, moves the specified snippet to the specified group.
|
UserEntity |
updateUser(Revision revision,
UserDTO userDTO)
Updates the specified user.
|
UserGroupEntity |
updateUserGroup(Revision revision,
UserGroupDTO userGroupDTO)
Updates the specified user group.
|
VariableRegistryEntity |
updateVariableRegistry(NiFiUser user,
Revision revision,
VariableRegistryDTO variableRegistryDto)
Updates the variable registry on behalf of the given user
|
VariableRegistryEntity |
updateVariableRegistry(Revision revision,
VariableRegistryDTO variableRegistryDto)
Updates the variable registry on behalf of the user currently logged in
|
void |
verifyActivateControllerServices(java.lang.String groupId,
ControllerServiceState state,
java.util.Set<java.lang.String> serviceIds)
Verifies the controller services with the given ID's can be enabled or disabled
|
void |
verifyCanAddTemplate(java.lang.String groupId,
java.lang.String name)
Verifies a template with the specified name can be created.
|
void |
verifyCanClearControllerServiceState(java.lang.String controllerServiceId)
Verifies the controller service state could be cleared.
|
void |
verifyCanClearProcessorState(java.lang.String processorId)
Verifies the processor state could be cleared.
|
void |
verifyCanClearReportingTaskState(java.lang.String reportingTaskId)
Verifies the reporting task state could be cleared.
|
void |
verifyComponentTypes(FlowSnippetDTO snippet)
Verifies the types of components in a template.
|
void |
verifyCreateConnection(java.lang.String groupId,
ConnectionDTO connectionDTO)
Determines if this connection can be created.
|
void |
verifyCreateControllerService(ControllerServiceDTO controllerServiceDTO)
Verifies the specified controller service can be created.
|
void |
verifyCreateProcessor(ProcessorDTO processorDTO)
Verifies the specified processor can be created.
|
void |
verifyCreateReportingTask(ReportingTaskDTO reportingTaskDTO)
Verifies the specified reporting task can be created.
|
void |
verifyDeleteConnection(java.lang.String connectionId)
Determines if this connection can be removed.
|
void |
verifyDeleteControllerService(java.lang.String controllerServiceId)
Verifies the specified controller service can be removed.
|
void |
verifyDeleteFunnel(java.lang.String funnelId)
Verifies the specified funnel can be deleted.
|
void |
verifyDeleteInputPort(java.lang.String inputPortId)
Determines if the input port could be deleted.
|
void |
verifyDeleteOutputPort(java.lang.String outputPortId)
Determines if the output port could be deleted.
|
void |
verifyDeleteProcessGroup(java.lang.String groupId)
Verifies the specified process group can be removed.
|
void |
verifyDeleteProcessor(java.lang.String processorId)
Verifies the specified processor can be removed.
|
void |
verifyDeleteRemoteProcessGroup(java.lang.String remoteProcessGroupId)
Verifies the remote process group can be deleted.
|
void |
verifyDeleteReportingTask(java.lang.String reportingTaskId)
Verifies the specified reporting task can be removed.
|
void |
verifyDeleteSnippet(java.lang.String snippetId,
java.util.Set<java.lang.String> affectedComponentIds)
Determines if this snippet can be removed.
|
void |
verifyListQueue(java.lang.String connectionId)
Determines if this connection can be listed.
|
void |
verifyRevision(Revision revision,
NiFiUser user)
Claims the specified revision for the specified user.
|
void |
verifyRevisions(java.util.Set<Revision> revisions,
NiFiUser user)
Claims the specified revisions for the specified user.
|
void |
verifyScheduleComponents(java.lang.String groupId,
ScheduledState state,
java.util.Set<java.lang.String> componentIds)
Verifies the contents of the specified process group can be scheduled or unscheduled.
|
void |
verifyUpdateConnection(ConnectionDTO connectionDTO)
Determines if this connection can be updated.
|
void |
verifyUpdateControllerService(ControllerServiceDTO controllerServiceDTO)
Verifies the specified controller service can be updated.
|
void |
verifyUpdateControllerServiceReferencingComponents(java.lang.String controllerServiceId,
ScheduledState scheduledState,
ControllerServiceState controllerServiceState)
Verifies the referencing components of the specified controller service can be updated.
|
void |
verifyUpdateInputPort(PortDTO inputPortDTO)
Determines if the input port could be updated.
|
void |
verifyUpdateOutputPort(PortDTO outputPortDTO)
Determines if the output port could be updated.
|
void |
verifyUpdateProcessGroup(ProcessGroupDTO processGroupDTO)
Verifies that the Process Group identified by the given DTO can be updated in the manner appropriate according
to the DTO
|
void |
verifyUpdateProcessor(ProcessorDTO processorDTO)
Verifies the specified processor can be updated.
|
void |
verifyUpdateRemoteProcessGroup(RemoteProcessGroupDTO remoteProcessGroupDTO)
Verifies the specified remote process group can be updated.
|
void |
verifyUpdateRemoteProcessGroupInputPort(java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
Verifies the specified remote process group can update the specified remote input port.
|
void |
verifyUpdateRemoteProcessGroupOutputPort(java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
Verifies the specified remote process group can update the specified remote output port.
|
void |
verifyUpdateReportingTask(ReportingTaskDTO reportingTaskDTO)
Verifies the specified reporting task can be updated.
|
void |
verifyUpdateSnippet(SnippetDTO snippetDto,
java.util.Set<java.lang.String> affectedComponentIds)
Determines if this snippet can be updated.
|
public void authorizeAccess(AuthorizeAccess authorizeAccess)
NiFiServiceFacadeauthorizeAccess in interface NiFiServiceFacadeauthorizeAccess - authorize access callbackpublic void verifyRevision(Revision revision, NiFiUser user)
NiFiServiceFacadeverifyRevision in interface NiFiServiceFacaderevision - revisionuser - userpublic void verifyRevisions(java.util.Set<Revision> revisions, NiFiUser user)
NiFiServiceFacadeverifyRevisions in interface NiFiServiceFacaderevisions - revisionsuser - userpublic java.util.Set<Revision> getRevisionsFromGroup(java.lang.String groupId, java.util.function.Function<ProcessGroup,java.util.Set<java.lang.String>> getComponents)
NiFiServiceFacadegetRevisionsFromGroup in interface NiFiServiceFacadegroupId - groupgetComponents - callbackpublic java.util.Set<Revision> getRevisionsFromSnippet(java.lang.String snippetId)
NiFiServiceFacadegetRevisionsFromSnippet in interface NiFiServiceFacadesnippetId - snippetpublic void verifyListQueue(java.lang.String connectionId)
NiFiServiceFacadeverifyListQueue in interface NiFiServiceFacadeconnectionId - connectionpublic void verifyCreateConnection(java.lang.String groupId,
ConnectionDTO connectionDTO)
NiFiServiceFacadeverifyCreateConnection in interface NiFiServiceFacadegroupId - groupconnectionDTO - connectionpublic void verifyUpdateConnection(ConnectionDTO connectionDTO)
NiFiServiceFacadeverifyUpdateConnection in interface NiFiServiceFacadeconnectionDTO - connectionpublic void verifyDeleteConnection(java.lang.String connectionId)
NiFiServiceFacadeverifyDeleteConnection in interface NiFiServiceFacadeconnectionId - connectionpublic void verifyDeleteFunnel(java.lang.String funnelId)
NiFiServiceFacadeverifyDeleteFunnel in interface NiFiServiceFacadefunnelId - funnelpublic void verifyUpdateInputPort(PortDTO inputPortDTO)
NiFiServiceFacadeverifyUpdateInputPort in interface NiFiServiceFacadeinputPortDTO - The id of the input portpublic void verifyDeleteInputPort(java.lang.String inputPortId)
NiFiServiceFacadeverifyDeleteInputPort in interface NiFiServiceFacadeinputPortId - The id of the input portpublic void verifyUpdateOutputPort(PortDTO outputPortDTO)
NiFiServiceFacadeverifyUpdateOutputPort in interface NiFiServiceFacadeoutputPortDTO - The id of the output portpublic void verifyDeleteOutputPort(java.lang.String outputPortId)
NiFiServiceFacadeverifyDeleteOutputPort in interface NiFiServiceFacadeoutputPortId - The id of the output portpublic void verifyCreateProcessor(ProcessorDTO processorDTO)
NiFiServiceFacadeverifyCreateProcessor in interface NiFiServiceFacadeprocessorDTO - processorpublic void verifyUpdateProcessor(ProcessorDTO processorDTO)
NiFiServiceFacadeverifyUpdateProcessor in interface NiFiServiceFacadeprocessorDTO - processorpublic void verifyDeleteProcessor(java.lang.String processorId)
NiFiServiceFacadeverifyDeleteProcessor in interface NiFiServiceFacadeprocessorId - processorpublic void verifyScheduleComponents(java.lang.String groupId,
ScheduledState state,
java.util.Set<java.lang.String> componentIds)
NiFiServiceFacadeverifyScheduleComponents in interface NiFiServiceFacadegroupId - The ProcessGroup idstate - scheduled statecomponentIds - the componentspublic void verifyActivateControllerServices(java.lang.String groupId,
ControllerServiceState state,
java.util.Set<java.lang.String> serviceIds)
NiFiServiceFacadeverifyActivateControllerServices in interface NiFiServiceFacadegroupId - the ID of the process groupstate - the stateserviceIds - the id's of the servicespublic void verifyDeleteProcessGroup(java.lang.String groupId)
NiFiServiceFacadeverifyDeleteProcessGroup in interface NiFiServiceFacadegroupId - The id of the process grouppublic void verifyUpdateRemoteProcessGroup(RemoteProcessGroupDTO remoteProcessGroupDTO)
NiFiServiceFacadeverifyUpdateRemoteProcessGroup in interface NiFiServiceFacaderemoteProcessGroupDTO - The RemoteProcessGroupDTOpublic void verifyUpdateRemoteProcessGroupInputPort(java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
NiFiServiceFacadeverifyUpdateRemoteProcessGroupInputPort in interface NiFiServiceFacaderemoteProcessGroupId - The id of the remote process groupremoteProcessGroupPortDTO - The RemoteProcessGroupPortDTOpublic void verifyUpdateRemoteProcessGroupOutputPort(java.lang.String remoteProcessGroupId,
RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
NiFiServiceFacadeverifyUpdateRemoteProcessGroupOutputPort in interface NiFiServiceFacaderemoteProcessGroupId - The id of the remote process groupremoteProcessGroupPortDTO - The RemoteProcessGroupPortDTOpublic void verifyDeleteRemoteProcessGroup(java.lang.String remoteProcessGroupId)
NiFiServiceFacadeverifyDeleteRemoteProcessGroup in interface NiFiServiceFacaderemoteProcessGroupId - The id of the remote process grouppublic void verifyCreateControllerService(ControllerServiceDTO controllerServiceDTO)
NiFiServiceFacadeverifyCreateControllerService in interface NiFiServiceFacadecontrollerServiceDTO - servicepublic void verifyUpdateControllerService(ControllerServiceDTO controllerServiceDTO)
NiFiServiceFacadeverifyUpdateControllerService in interface NiFiServiceFacadecontrollerServiceDTO - servicepublic void verifyUpdateControllerServiceReferencingComponents(java.lang.String controllerServiceId,
ScheduledState scheduledState,
ControllerServiceState controllerServiceState)
NiFiServiceFacadeverifyUpdateControllerServiceReferencingComponents in interface NiFiServiceFacadecontrollerServiceId - idscheduledState - schedule statecontrollerServiceState - service statepublic void verifyDeleteControllerService(java.lang.String controllerServiceId)
NiFiServiceFacadeverifyDeleteControllerService in interface NiFiServiceFacadecontrollerServiceId - idpublic void verifyCreateReportingTask(ReportingTaskDTO reportingTaskDTO)
NiFiServiceFacadeverifyCreateReportingTask in interface NiFiServiceFacadereportingTaskDTO - taskpublic void verifyUpdateReportingTask(ReportingTaskDTO reportingTaskDTO)
NiFiServiceFacadeverifyUpdateReportingTask in interface NiFiServiceFacadereportingTaskDTO - taskpublic void verifyDeleteReportingTask(java.lang.String reportingTaskId)
NiFiServiceFacadeverifyDeleteReportingTask in interface NiFiServiceFacadereportingTaskId - idpublic AccessPolicyEntity updateAccessPolicy(Revision revision, AccessPolicyDTO accessPolicyDTO)
NiFiServiceFacadeupdateAccessPolicy in interface NiFiServiceFacaderevision - Revision to compare with current base revisionaccessPolicyDTO - The access policy DTOpublic UserEntity updateUser(Revision revision, UserDTO userDTO)
NiFiServiceFacadeupdateUser in interface NiFiServiceFacaderevision - Revision to compare with current base revisionuserDTO - The user DTOpublic UserGroupEntity updateUserGroup(Revision revision, UserGroupDTO userGroupDTO)
NiFiServiceFacadeupdateUserGroup in interface NiFiServiceFacaderevision - Revision to compare with current base revisionuserGroupDTO - The user group DTOpublic ConnectionEntity updateConnection(Revision revision, ConnectionDTO connectionDTO)
NiFiServiceFacadeupdateConnection in interface NiFiServiceFacaderevision - Revision to compare with current base revisionconnectionDTO - The Connection DTOpublic ProcessorEntity updateProcessor(Revision revision, ProcessorDTO processorDTO)
NiFiServiceFacadeupdateProcessor in interface NiFiServiceFacaderevision - Revision to compare with current base revisionprocessorDTO - The processorDTOpublic LabelEntity updateLabel(Revision revision, LabelDTO labelDTO)
NiFiServiceFacadeupdateLabel in interface NiFiServiceFacaderevision - Revision to compare with current base revisionlabelDTO - The label DTOpublic FunnelEntity updateFunnel(Revision revision, FunnelDTO funnelDTO)
NiFiServiceFacadeupdateFunnel in interface NiFiServiceFacaderevision - Revision to compare with current base revisionfunnelDTO - The funnel DTOpublic void verifyUpdateSnippet(SnippetDTO snippetDto, java.util.Set<java.lang.String> affectedComponentIds)
NiFiServiceFacadeverifyUpdateSnippet in interface NiFiServiceFacadesnippetDto - snippetpublic SnippetEntity updateSnippet(java.util.Set<Revision> revisions, SnippetDTO snippetDto)
NiFiServiceFacadeupdateSnippet in interface NiFiServiceFacaderevisions - revisionssnippetDto - snippetpublic PortEntity updateInputPort(Revision revision, PortDTO inputPortDTO)
NiFiServiceFacadeupdateInputPort in interface NiFiServiceFacaderevision - Revision to compare with current base revisioninputPortDTO - The input PortDTOpublic PortEntity updateOutputPort(Revision revision, PortDTO outputPortDTO)
NiFiServiceFacadeupdateOutputPort in interface NiFiServiceFacaderevision - Revision to compare with current base revisionoutputPortDTO - The output PortDTOpublic RemoteProcessGroupEntity updateRemoteProcessGroup(Revision revision, RemoteProcessGroupDTO remoteProcessGroupDTO)
NiFiServiceFacadeupdateRemoteProcessGroup in interface NiFiServiceFacaderevision - Revision to compare with current base revisionremoteProcessGroupDTO - The RemoteProcessGroupDTOpublic RemoteProcessGroupPortEntity updateRemoteProcessGroupInputPort(Revision revision, java.lang.String remoteProcessGroupId, RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
NiFiServiceFacadeupdateRemoteProcessGroupInputPort in interface NiFiServiceFacaderevision - Revision to compare with current base revisionremoteProcessGroupId - The id of the remote process groupremoteProcessGroupPortDTO - The RemoteProcessGroupPortDTOpublic RemoteProcessGroupPortEntity updateRemoteProcessGroupOutputPort(Revision revision, java.lang.String remoteProcessGroupId, RemoteProcessGroupPortDTO remoteProcessGroupPortDTO)
NiFiServiceFacadeupdateRemoteProcessGroupOutputPort in interface NiFiServiceFacaderevision - Revision to compare with current base revisionremoteProcessGroupId - The id of the remote process groupremoteProcessGroupPortDTO - The RemoteProcessGroupPortDTOpublic java.util.Set<AffectedComponentDTO> getActiveComponentsAffectedByVariableRegistryUpdate(VariableRegistryDTO variableRegistryDto)
NiFiServiceFacadegetActiveComponentsAffectedByVariableRegistryUpdate in interface NiFiServiceFacadevariableRegistryDto - the variable registrypublic java.util.Set<AffectedComponentEntity> getComponentsAffectedByVariableRegistryUpdate(VariableRegistryDTO variableRegistryDto)
NiFiServiceFacadegetComponentsAffectedByVariableRegistryUpdate in interface NiFiServiceFacadevariableRegistryDto - the variable registrypublic VariableRegistryEntity updateVariableRegistry(Revision revision, VariableRegistryDTO variableRegistryDto)
NiFiServiceFacadeupdateVariableRegistry in interface NiFiServiceFacaderevision - Revision to compare with current base revisionvariableRegistryDto - the Variable Registrypublic VariableRegistryEntity updateVariableRegistry(NiFiUser user, Revision revision, VariableRegistryDTO variableRegistryDto)
NiFiServiceFacadeupdateVariableRegistry in interface NiFiServiceFacadeuser - the user who performed the actionrevision - Revision to compare with current base revisionvariableRegistryDto - the Variable Registrypublic ProcessGroupEntity updateProcessGroup(Revision revision, ProcessGroupDTO processGroupDTO)
NiFiServiceFacadeupdateProcessGroup in interface NiFiServiceFacaderevision - Revision to compare with current base revisionprocessGroupDTO - The ProcessGroupDTOpublic void verifyUpdateProcessGroup(ProcessGroupDTO processGroupDTO)
NiFiServiceFacadeverifyUpdateProcessGroup in interface NiFiServiceFacadeprocessGroupDTO - the DTO that indicates the updates to occurpublic ScheduleComponentsEntity scheduleComponents(java.lang.String processGroupId, ScheduledState state, java.util.Map<java.lang.String,Revision> componentRevisions)
NiFiServiceFacadescheduleComponents in interface NiFiServiceFacadeprocessGroupId - The ProcessGroup idstate - schedule statecomponentRevisions - components and their revisionpublic ScheduleComponentsEntity scheduleComponents(NiFiUser user, java.lang.String processGroupId, ScheduledState state, java.util.Map<java.lang.String,Revision> componentRevisions)
NiFiServiceFacadescheduleComponents in interface NiFiServiceFacadeuser - the user performing the actionprocessGroupId - The ProcessGroup idstate - schedule statecomponentRevisions - components and their revisionpublic ActivateControllerServicesEntity activateControllerServices(java.lang.String processGroupId, ControllerServiceState state, java.util.Map<java.lang.String,Revision> serviceRevisions)
NiFiServiceFacadeactivateControllerServices in interface NiFiServiceFacadeprocessGroupId - the ID of the process groupstate - the desired state of the servicesserviceRevisions - a mapping of Controller Service ID to current Revisionpublic ActivateControllerServicesEntity activateControllerServices(NiFiUser user, java.lang.String processGroupId, ControllerServiceState state, java.util.Map<java.lang.String,Revision> serviceRevisions)
NiFiServiceFacadeactivateControllerServices in interface NiFiServiceFacadeuser - the user performing the actionprocessGroupId - the ID of the process groupstate - the desired state of the servicesserviceRevisions - a mapping of Controller Service ID to current Revisionpublic ControllerConfigurationEntity updateControllerConfiguration(Revision revision, ControllerConfigurationDTO controllerConfigurationDTO)
NiFiServiceFacadeupdateControllerConfiguration in interface NiFiServiceFacaderevision - Revision to compare with current base revisioncontrollerConfigurationDTO - Controller configuration DTOpublic NodeDTO updateNode(NodeDTO nodeDTO)
NiFiServiceFacadeupdateNode in interface NiFiServiceFacadenodeDTO - a node transfer objectpublic CounterDTO updateCounter(java.lang.String counterId)
NiFiServiceFacadeupdateCounter in interface NiFiServiceFacadecounterId - idpublic void verifyCanClearProcessorState(java.lang.String processorId)
NiFiServiceFacadeverifyCanClearProcessorState in interface NiFiServiceFacadeprocessorId - the processor idpublic void clearProcessorState(java.lang.String processorId)
NiFiServiceFacadeclearProcessorState in interface NiFiServiceFacadeprocessorId - the processor idpublic void verifyCanClearControllerServiceState(java.lang.String controllerServiceId)
NiFiServiceFacadeverifyCanClearControllerServiceState in interface NiFiServiceFacadecontrollerServiceId - the controller service idpublic void clearControllerServiceState(java.lang.String controllerServiceId)
NiFiServiceFacadeclearControllerServiceState in interface NiFiServiceFacadecontrollerServiceId - the controller service idpublic void verifyCanClearReportingTaskState(java.lang.String reportingTaskId)
NiFiServiceFacadeverifyCanClearReportingTaskState in interface NiFiServiceFacadereportingTaskId - the reporting task idpublic void clearReportingTaskState(java.lang.String reportingTaskId)
NiFiServiceFacadeclearReportingTaskState in interface NiFiServiceFacadereportingTaskId - the reporting task idpublic ConnectionEntity deleteConnection(Revision revision, java.lang.String connectionId)
NiFiServiceFacadedeleteConnection in interface NiFiServiceFacaderevision - Revision to compare with current base revisionconnectionId - The ID of the connectionpublic DropRequestDTO deleteFlowFileDropRequest(java.lang.String connectionId, java.lang.String dropRequestId)
NiFiServiceFacadedeleteFlowFileDropRequest in interface NiFiServiceFacadeconnectionId - The ID of the connectiondropRequestId - The flow file drop requestpublic ListingRequestDTO deleteFlowFileListingRequest(java.lang.String connectionId, java.lang.String listingRequestId)
NiFiServiceFacadedeleteFlowFileListingRequest in interface NiFiServiceFacadeconnectionId - The ID of the connectionlistingRequestId - The ID of the listing requestpublic ProcessorEntity deleteProcessor(Revision revision, java.lang.String processorId)
NiFiServiceFacadedeleteProcessor in interface NiFiServiceFacaderevision - Revision to compare with current base revisionprocessorId - The processor id to deletepublic LabelEntity deleteLabel(Revision revision, java.lang.String labelId)
NiFiServiceFacadedeleteLabel in interface NiFiServiceFacaderevision - Revision to compare with current base revisionlabelId - The label idpublic UserEntity deleteUser(Revision revision, java.lang.String userId)
NiFiServiceFacadedeleteUser in interface NiFiServiceFacaderevision - Revision to compare with current base revisionuserId - The user IDpublic UserGroupEntity deleteUserGroup(Revision revision, java.lang.String userGroupId)
NiFiServiceFacadedeleteUserGroup in interface NiFiServiceFacaderevision - Revision to compare with current base revisionuserGroupId - The user group IDpublic AccessPolicyEntity deleteAccessPolicy(Revision revision, java.lang.String accessPolicyId)
NiFiServiceFacadedeleteAccessPolicy in interface NiFiServiceFacaderevision - Revision to compare with current base revisionaccessPolicyId - The access policy IDpublic FunnelEntity deleteFunnel(Revision revision, java.lang.String funnelId)
NiFiServiceFacadedeleteFunnel in interface NiFiServiceFacaderevision - Revision to compare with current base revisionfunnelId - The funnel idpublic void verifyDeleteSnippet(java.lang.String snippetId,
java.util.Set<java.lang.String> affectedComponentIds)
NiFiServiceFacadeverifyDeleteSnippet in interface NiFiServiceFacadesnippetId - idaffectedComponentIds - affected componentspublic SnippetEntity deleteSnippet(java.util.Set<Revision> revisions, java.lang.String snippetId)
NiFiServiceFacadedeleteSnippet in interface NiFiServiceFacaderevisions - revisionssnippetId - snippetpublic PortEntity deleteInputPort(Revision revision, java.lang.String inputPortId)
NiFiServiceFacadedeleteInputPort in interface NiFiServiceFacaderevision - Revision to compare with current base revisioninputPortId - The id of the input portpublic PortEntity deleteOutputPort(Revision revision, java.lang.String outputPortId)
NiFiServiceFacadedeleteOutputPort in interface NiFiServiceFacaderevision - revisionoutputPortId - The id of the output portpublic ProcessGroupEntity deleteProcessGroup(Revision revision, java.lang.String groupId)
NiFiServiceFacadedeleteProcessGroup in interface NiFiServiceFacaderevision - Revision to compare with current base revisiongroupId - The id of the process grouppublic RemoteProcessGroupEntity deleteRemoteProcessGroup(Revision revision, java.lang.String remoteProcessGroupId)
NiFiServiceFacadedeleteRemoteProcessGroup in interface NiFiServiceFacaderevision - Revision to compare with current base revisionremoteProcessGroupId - The id of the remote process grouppublic void deleteTemplate(java.lang.String id)
NiFiServiceFacadedeleteTemplate in interface NiFiServiceFacadeid - The id of the templatepublic ConnectionEntity createConnection(Revision revision, java.lang.String groupId, ConnectionDTO connectionDTO)
NiFiServiceFacadecreateConnection in interface NiFiServiceFacaderevision - revisiongroupId - groupconnectionDTO - The Connection DTOpublic DropRequestDTO createFlowFileDropRequest(java.lang.String connectionId, java.lang.String dropRequestId)
NiFiServiceFacadecreateFlowFileDropRequest in interface NiFiServiceFacadeconnectionId - The ID of the connectiondropRequestId - The ID of the drop requestpublic ListingRequestDTO createFlowFileListingRequest(java.lang.String connectionId, java.lang.String listingRequestId)
NiFiServiceFacadecreateFlowFileListingRequest in interface NiFiServiceFacadeconnectionId - The ID of the connectionlistingRequestId - The ID of the listing requestpublic ProcessorEntity createProcessor(Revision revision, java.lang.String groupId, ProcessorDTO processorDTO)
NiFiServiceFacadecreateProcessor in interface NiFiServiceFacaderevision - revisiongroupId - Group idprocessorDTO - The processor DTOpublic LabelEntity createLabel(Revision revision, java.lang.String groupId, LabelDTO labelDTO)
NiFiServiceFacadecreateLabel in interface NiFiServiceFacaderevision - revisiongroupId - grouplabelDTO - The label DTOpublic BulletinEntity createBulletin(BulletinDTO bulletinDTO, java.lang.Boolean canRead)
NiFiServiceFacadecreateBulletin in interface NiFiServiceFacadebulletinDTO - bulletin to send to userscanRead - allow users to read bulletinpublic FunnelEntity createFunnel(Revision revision, java.lang.String groupId, FunnelDTO funnelDTO)
NiFiServiceFacadecreateFunnel in interface NiFiServiceFacaderevision - revisiongroupId - groupfunnelDTO - funnelpublic AccessPolicyEntity createAccessPolicy(Revision revision, AccessPolicyDTO accessPolicyDTO)
NiFiServiceFacadecreateAccessPolicy in interface NiFiServiceFacaderevision - The starting revisionaccessPolicyDTO - The access policy DTOpublic UserEntity createUser(Revision revision, UserDTO userDTO)
NiFiServiceFacadecreateUser in interface NiFiServiceFacaderevision - The starting revisionuserDTO - The user DTOpublic UserGroupEntity createUserGroup(Revision revision, UserGroupDTO userGroupDTO)
NiFiServiceFacadecreateUserGroup in interface NiFiServiceFacaderevision - The starting revisionuserGroupDTO - The user group DTOpublic FlowEntity copySnippet(java.lang.String groupId, java.lang.String snippetId, java.lang.Double originX, java.lang.Double originY, java.lang.String idGenerationSeed)
NiFiServiceFacadecopySnippet in interface NiFiServiceFacadegroupId - group idsnippetId - snippet idoriginX - xoriginY - yidGenerationSeed - the seed to use for generating UUID's. May be null.public SnippetEntity createSnippet(SnippetDTO snippetDTO)
NiFiServiceFacadecreateSnippet in interface NiFiServiceFacadesnippetDTO - snippetpublic PortEntity createInputPort(Revision revision, java.lang.String groupId, PortDTO inputPortDTO)
NiFiServiceFacadecreateInputPort in interface NiFiServiceFacaderevision - revisiongroupId - The id of the group this port should be create ininputPortDTO - The input PortDTOpublic PortEntity createOutputPort(Revision revision, java.lang.String groupId, PortDTO outputPortDTO)
NiFiServiceFacadecreateOutputPort in interface NiFiServiceFacaderevision - revisiongroupId - The id of the group this port should be create inoutputPortDTO - The output PortDTOpublic ProcessGroupEntity createProcessGroup(Revision revision, java.lang.String parentGroupId, ProcessGroupDTO processGroupDTO)
NiFiServiceFacadecreateProcessGroup in interface NiFiServiceFacaderevision - revisionparentGroupId - The id of the parent groupprocessGroupDTO - The ProcessGroupDTOpublic RemoteProcessGroupEntity createRemoteProcessGroup(Revision revision, java.lang.String groupId, RemoteProcessGroupDTO remoteProcessGroupDTO)
NiFiServiceFacadecreateRemoteProcessGroup in interface NiFiServiceFacaderevision - revisiongroupId - The id of the parent groupremoteProcessGroupDTO - The RemoteProcessGroupDTOpublic void verifyCanAddTemplate(java.lang.String groupId,
java.lang.String name)
NiFiServiceFacadeverifyCanAddTemplate in interface NiFiServiceFacadegroupId - the id of the group for the templatename - name of proposed templatepublic void verifyComponentTypes(FlowSnippetDTO snippet)
NiFiServiceFacadeverifyComponentTypes in interface NiFiServiceFacadesnippet - proposed templatepublic TemplateDTO createTemplate(java.lang.String name, java.lang.String description, java.lang.String snippetId, java.lang.String groupId, java.util.Optional<java.lang.String> idGenerationSeed)
NiFiServiceFacadecreateTemplate in interface NiFiServiceFacadename - namedescription - descriptionsnippetId - idgroupId - id of the process groupidGenerationSeed - the seed to use for generating a UUIDpublic TemplateDTO importTemplate(TemplateDTO templateDTO, java.lang.String groupId, java.util.Optional<java.lang.String> idGenerationSeed)
NiFiServiceFacadeimportTemplate in interface NiFiServiceFacadetemplateDTO - The template dtogroupId - id of the process groupidGenerationSeed - the seed to use for generating a UUIDpublic FlowEntity createTemplateInstance(java.lang.String groupId, java.lang.Double originX, java.lang.Double originY, java.lang.String templateEncodingVersion, FlowSnippetDTO requestSnippet, java.lang.String idGenerationSeed)
NiFiServiceFacadecreateTemplateInstance in interface NiFiServiceFacadegroupId - group idoriginX - xoriginY - ytemplateEncodingVersion - template encoding versionrequestSnippet - template snippetidGenerationSeed - the ID to use for generating UUID's. May be null.public ControllerServiceEntity createControllerService(Revision revision, java.lang.String groupId, ControllerServiceDTO controllerServiceDTO)
NiFiServiceFacadecreateControllerService in interface NiFiServiceFacaderevision - revisiongroupId - the ID of the Process Group to add the Controller Service tocontrollerServiceDTO - The controller service DTOpublic ControllerServiceEntity updateControllerService(Revision revision, ControllerServiceDTO controllerServiceDTO)
NiFiServiceFacadeupdateControllerService in interface NiFiServiceFacaderevision - Revision to compare with current base revisioncontrollerServiceDTO - The controller service DTOpublic ControllerServiceReferencingComponentsEntity updateControllerServiceReferencingComponents(java.util.Map<java.lang.String,Revision> referenceRevisions, java.lang.String controllerServiceId, ScheduledState scheduledState, ControllerServiceState controllerServiceState)
NiFiServiceFacadeupdateControllerServiceReferencingComponents in interface NiFiServiceFacadereferenceRevisions - revisionscontrollerServiceId - idscheduledState - statecontrollerServiceState - the value of statepublic ControllerServiceEntity deleteControllerService(Revision revision, java.lang.String controllerServiceId)
NiFiServiceFacadedeleteControllerService in interface NiFiServiceFacaderevision - Revision to compare with current base revisioncontrollerServiceId - The controller service idpublic ReportingTaskEntity createReportingTask(Revision revision, ReportingTaskDTO reportingTaskDTO)
NiFiServiceFacadecreateReportingTask in interface NiFiServiceFacaderevision - revisionreportingTaskDTO - The reporting task DTOpublic ReportingTaskEntity updateReportingTask(Revision revision, ReportingTaskDTO reportingTaskDTO)
NiFiServiceFacadeupdateReportingTask in interface NiFiServiceFacaderevision - Revision to compare with current base revisionreportingTaskDTO - The reporting task DTOpublic ReportingTaskEntity deleteReportingTask(Revision revision, java.lang.String reportingTaskId)
NiFiServiceFacadedeleteReportingTask in interface NiFiServiceFacaderevision - Revision to compare with current base revisionreportingTaskId - The reporting task idpublic void deleteActions(java.util.Date endDate)
NiFiServiceFacadedeleteActions in interface NiFiServiceFacadeendDate - The end datepublic ProvenanceDTO submitProvenance(ProvenanceDTO query)
NiFiServiceFacadesubmitProvenance in interface NiFiServiceFacadequery - querypublic void deleteProvenance(java.lang.String queryId)
NiFiServiceFacadedeleteProvenance in interface NiFiServiceFacadequeryId - identifierpublic LineageDTO submitLineage(LineageDTO lineage)
NiFiServiceFacadesubmitLineage in interface NiFiServiceFacadelineage - lineagepublic void deleteLineage(java.lang.String lineageId)
NiFiServiceFacadedeleteLineage in interface NiFiServiceFacadelineageId - lineagepublic ProvenanceEventDTO submitReplay(java.lang.Long eventId)
NiFiServiceFacadesubmitReplay in interface NiFiServiceFacadeeventId - idpublic SearchResultsDTO searchController(java.lang.String query)
NiFiServiceFacadesearchController in interface NiFiServiceFacadequery - querypublic DownloadableContent getContent(java.lang.String connectionId, java.lang.String flowFileUuid, java.lang.String uri)
NiFiServiceFacadegetContent in interface NiFiServiceFacadeconnectionId - connectionflowFileUuid - flowfileuri - uripublic DownloadableContent getContent(java.lang.Long eventId, java.lang.String uri, ContentDirection contentDirection)
NiFiServiceFacadegetContent in interface NiFiServiceFacadeeventId - iduri - uricontentDirection - directionpublic ProvenanceDTO getProvenance(java.lang.String queryId, java.lang.Boolean summarize, java.lang.Boolean incrementalResults)
NiFiServiceFacadegetProvenance in interface NiFiServiceFacadequeryId - identifiersummarize - whether to summarize the event dtosincrementalResults - whether to return any events if the search has not finishedpublic LineageDTO getLineage(java.lang.String lineageId)
NiFiServiceFacadegetLineage in interface NiFiServiceFacadelineageId - idpublic ProvenanceOptionsDTO getProvenanceSearchOptions()
NiFiServiceFacadegetProvenanceSearchOptions in interface NiFiServiceFacadepublic ProvenanceEventDTO getProvenanceEvent(java.lang.Long id)
NiFiServiceFacadegetProvenanceEvent in interface NiFiServiceFacadeid - idpublic ProcessGroupStatusEntity getProcessGroupStatus(java.lang.String groupId, boolean recursive)
NiFiServiceFacadegetProcessGroupStatus in interface NiFiServiceFacadegroupId - grouppublic ControllerStatusDTO getControllerStatus()
NiFiServiceFacadegetControllerStatus in interface NiFiServiceFacadepublic ComponentStateDTO getProcessorState(java.lang.String processorId)
NiFiServiceFacadegetProcessorState in interface NiFiServiceFacadeprocessorId - the processor idpublic ComponentStateDTO getControllerServiceState(java.lang.String controllerServiceId)
NiFiServiceFacadegetControllerServiceState in interface NiFiServiceFacadecontrollerServiceId - the controller service idpublic ComponentStateDTO getReportingTaskState(java.lang.String reportingTaskId)
NiFiServiceFacadegetReportingTaskState in interface NiFiServiceFacadereportingTaskId - the reporting task idpublic CountersDTO getCounters()
NiFiServiceFacadegetCounters in interface NiFiServiceFacadepublic java.util.Set<ConnectionEntity> getConnections(java.lang.String groupId)
NiFiServiceFacadegetConnections in interface NiFiServiceFacadegroupId - grouppublic ConnectionEntity getConnection(java.lang.String connectionId)
NiFiServiceFacadegetConnection in interface NiFiServiceFacadeconnectionId - The ID of the connectionpublic DropRequestDTO getFlowFileDropRequest(java.lang.String connectionId, java.lang.String dropRequestId)
NiFiServiceFacadegetFlowFileDropRequest in interface NiFiServiceFacadeconnectionId - The ID of the connectiondropRequestId - The flow file drop requestpublic ListingRequestDTO getFlowFileListingRequest(java.lang.String connectionId, java.lang.String listingRequestId)
NiFiServiceFacadegetFlowFileListingRequest in interface NiFiServiceFacadeconnectionId - The ID of the connectionlistingRequestId - The ID of the listing requestpublic FlowFileDTO getFlowFile(java.lang.String connectionId, java.lang.String flowFileUuid)
NiFiServiceFacadegetFlowFile in interface NiFiServiceFacadeconnectionId - The ID of the connectionflowFileUuid - The UUID of the flowfilepublic ConnectionStatusEntity getConnectionStatus(java.lang.String connectionId)
NiFiServiceFacadegetConnectionStatus in interface NiFiServiceFacadeconnectionId - connectionpublic StatusHistoryEntity getConnectionStatusHistory(java.lang.String connectionId)
NiFiServiceFacadegetConnectionStatusHistory in interface NiFiServiceFacadeconnectionId - connectionpublic java.util.Set<ProcessorEntity> getProcessors(java.lang.String groupId, boolean includeDescendants)
NiFiServiceFacadegetProcessors in interface NiFiServiceFacadegroupId - groupincludeDescendants - if processors from descendent groups should be includedpublic TemplateDTO exportTemplate(java.lang.String id)
NiFiServiceFacadeexportTemplate in interface NiFiServiceFacadeid - idpublic TemplateDTO getTemplate(java.lang.String id)
NiFiServiceFacadegetTemplate in interface NiFiServiceFacadeid - idpublic java.util.Set<TemplateEntity> getTemplates()
NiFiServiceFacadegetTemplates in interface NiFiServiceFacadepublic java.util.Set<DocumentedTypeDTO> getWorkQueuePrioritizerTypes()
NiFiServiceFacadegetWorkQueuePrioritizerTypes in interface NiFiServiceFacadepublic java.util.Set<DocumentedTypeDTO> getProcessorTypes(java.lang.String bundleGroup, java.lang.String bundleArtifact, java.lang.String type)
NiFiServiceFacadegetProcessorTypes in interface NiFiServiceFacadebundleGroup - if specified, must be member of bundle groupbundleArtifact - if specified, must be member of bundle artifacttype - if specified, type must matchpublic java.util.Set<DocumentedTypeDTO> getControllerServiceTypes(java.lang.String serviceType, java.lang.String serviceBundleGroup, java.lang.String serviceBundleArtifact, java.lang.String serviceBundleVersion, java.lang.String bundleGroup, java.lang.String bundleArtifact, java.lang.String type)
NiFiServiceFacadegetControllerServiceTypes in interface NiFiServiceFacadeserviceType - Filters only service types that implement this typeserviceBundleGroup - if serviceType specified, the bundle group of the serviceTypeserviceBundleArtifact - if serviceType specified, the bundle artifact of the serviceTypeserviceBundleVersion - if serviceType specified, the bundle version of the serviceTypebundleGroup - if specified, must be member of bundle groupbundleArtifact - if specified, must be member of bundle artifacttype - if specified, type must matchpublic java.util.Set<DocumentedTypeDTO> getReportingTaskTypes(java.lang.String bundleGroup, java.lang.String bundleArtifact, java.lang.String type)
NiFiServiceFacadegetReportingTaskTypes in interface NiFiServiceFacadebundleGroup - if specified, must be member of bundle groupbundleArtifact - if specified, must be member of bundle artifacttype - if specified, type must matchpublic ProcessorEntity getProcessor(java.lang.String id)
NiFiServiceFacadegetProcessor in interface NiFiServiceFacadeid - Id of the processor to returnpublic PropertyDescriptorDTO getProcessorPropertyDescriptor(java.lang.String id, java.lang.String property)
NiFiServiceFacadegetProcessorPropertyDescriptor in interface NiFiServiceFacadeid - idproperty - propertypublic ProcessorStatusEntity getProcessorStatus(java.lang.String id)
NiFiServiceFacadegetProcessorStatus in interface NiFiServiceFacadeid - idpublic StatusHistoryEntity getProcessorStatusHistory(java.lang.String id)
NiFiServiceFacadegetProcessorStatusHistory in interface NiFiServiceFacadeid - idpublic BulletinBoardDTO getBulletinBoard(BulletinQueryDTO query)
getBulletinBoard in interface NiFiServiceFacadequery - querypublic SystemDiagnosticsDTO getSystemDiagnostics()
getSystemDiagnostics in interface NiFiServiceFacadepublic java.util.List<ResourceDTO> getResources()
getResources in interface NiFiServiceFacadepublic ControllerDTO getSiteToSiteDetails()
getSiteToSiteDetails in interface NiFiServiceFacadepublic ControllerConfigurationEntity getControllerConfiguration()
NiFiServiceFacadegetControllerConfiguration in interface NiFiServiceFacadepublic ControllerBulletinsEntity getControllerBulletins()
NiFiServiceFacadegetControllerBulletins in interface NiFiServiceFacadepublic FlowConfigurationEntity getFlowConfiguration()
NiFiServiceFacadegetFlowConfiguration in interface NiFiServiceFacadepublic AccessPolicyEntity getAccessPolicy(java.lang.String accessPolicyId)
NiFiServiceFacadegetAccessPolicy in interface NiFiServiceFacadeaccessPolicyId - access policy IDpublic AccessPolicyEntity getAccessPolicy(RequestAction requestAction, java.lang.String resource)
NiFiServiceFacadegetAccessPolicy in interface NiFiServiceFacaderesource - resourcepublic UserEntity getUser(java.lang.String userId)
NiFiServiceFacadegetUser in interface NiFiServiceFacadeuserId - The user IDpublic java.util.Set<UserEntity> getUsers()
NiFiServiceFacadegetUsers in interface NiFiServiceFacadepublic UserGroupEntity getUserGroup(java.lang.String userGroupId)
NiFiServiceFacadegetUserGroup in interface NiFiServiceFacadeuserGroupId - The user group IDpublic java.util.Set<UserGroupEntity> getUserGroups()
NiFiServiceFacadegetUserGroups in interface NiFiServiceFacadepublic java.util.Set<LabelEntity> getLabels(java.lang.String groupId)
NiFiServiceFacadegetLabels in interface NiFiServiceFacadegroupId - grouppublic LabelEntity getLabel(java.lang.String labelId)
NiFiServiceFacadegetLabel in interface NiFiServiceFacadelabelId - The label idpublic java.util.Set<FunnelEntity> getFunnels(java.lang.String groupId)
NiFiServiceFacadegetFunnels in interface NiFiServiceFacadegroupId - grouppublic FunnelEntity getFunnel(java.lang.String funnelId)
NiFiServiceFacadegetFunnel in interface NiFiServiceFacadefunnelId - The funnel idpublic java.util.Set<PortEntity> getInputPorts(java.lang.String groupId)
NiFiServiceFacadegetInputPorts in interface NiFiServiceFacadegroupId - The id of the grouppublic java.util.Set<PortEntity> getOutputPorts(java.lang.String groupId)
NiFiServiceFacadegetOutputPorts in interface NiFiServiceFacadegroupId - The id of the grouppublic java.util.Set<ProcessGroupEntity> getProcessGroups(java.lang.String parentGroupId)
NiFiServiceFacadegetProcessGroups in interface NiFiServiceFacadeparentGroupId - The id of the parent grouppublic java.util.Set<RemoteProcessGroupEntity> getRemoteProcessGroups(java.lang.String groupId)
NiFiServiceFacadegetRemoteProcessGroups in interface NiFiServiceFacadegroupId - The id of the parent grouppublic PortEntity getInputPort(java.lang.String inputPortId)
NiFiServiceFacadegetInputPort in interface NiFiServiceFacadeinputPortId - The input port idpublic PortStatusEntity getInputPortStatus(java.lang.String inputPortId)
NiFiServiceFacadegetInputPortStatus in interface NiFiServiceFacadeinputPortId - input portpublic PortEntity getOutputPort(java.lang.String outputPortId)
NiFiServiceFacadegetOutputPort in interface NiFiServiceFacadeoutputPortId - The output port idpublic PortStatusEntity getOutputPortStatus(java.lang.String outputPortId)
NiFiServiceFacadegetOutputPortStatus in interface NiFiServiceFacadeoutputPortId - output portpublic RemoteProcessGroupEntity getRemoteProcessGroup(java.lang.String remoteProcessGroupId)
NiFiServiceFacadegetRemoteProcessGroup in interface NiFiServiceFacaderemoteProcessGroupId - The id of the remote process grouppublic RemoteProcessGroupStatusEntity getRemoteProcessGroupStatus(java.lang.String id)
NiFiServiceFacadegetRemoteProcessGroupStatus in interface NiFiServiceFacadeid - remote process grouppublic StatusHistoryEntity getRemoteProcessGroupStatusHistory(java.lang.String id)
NiFiServiceFacadegetRemoteProcessGroupStatusHistory in interface NiFiServiceFacadeid - The id of the remote process grouppublic CurrentUserEntity getCurrentUser()
getCurrentUser in interface NiFiServiceFacadepublic ProcessGroupFlowEntity getProcessGroupFlow(java.lang.String groupId)
NiFiServiceFacadegetProcessGroupFlow in interface NiFiServiceFacadegroupId - grouppublic ProcessGroupEntity getProcessGroup(java.lang.String groupId)
NiFiServiceFacadegetProcessGroup in interface NiFiServiceFacadegroupId - grouppublic VariableRegistryEntity getVariableRegistry(java.lang.String groupId, boolean includeAncestorGroups)
NiFiServiceFacadegetVariableRegistry in interface NiFiServiceFacadegroupId - the ID of the Process GroupincludeAncestorGroups - whether or not to include the variables that are defined in the the process group's parent group & its parent group, etc.public VariableRegistryEntity populateAffectedComponents(VariableRegistryDTO variableRegistryDto)
NiFiServiceFacadepopulateAffectedComponents in interface NiFiServiceFacadevariableRegistryDto - the Variable Registry that contains the variables of interestpublic java.util.Set<ControllerServiceEntity> getControllerServices(java.lang.String groupId, boolean includeAncestorGroups, boolean includeDescendantGroups)
NiFiServiceFacadegetControllerServices in interface NiFiServiceFacadegroupId - the id of the process group of interestincludeAncestorGroups - if true, parent and ancestor groups' services will be returned as wellincludeDescendantGroups - if true, child and descendant groups' services will be returned as wellpublic java.util.Set<ControllerServiceEntity> getControllerServices(java.lang.String groupId, boolean includeAncestorGroups, boolean includeDescendantGroups, NiFiUser user)
NiFiServiceFacadegetControllerServices in interface NiFiServiceFacadegroupId - the id of the process group of interestincludeAncestorGroups - if true, parent and ancestor groups' services will be returned as wellincludeDescendantGroups - if true, child and descendant groups' services will be returned as welluser - the user that is retrieving the Controller Servicespublic ControllerServiceEntity getControllerService(java.lang.String controllerServiceId)
NiFiServiceFacadegetControllerService in interface NiFiServiceFacadecontrollerServiceId - idpublic PropertyDescriptorDTO getControllerServicePropertyDescriptor(java.lang.String id, java.lang.String property)
NiFiServiceFacadegetControllerServicePropertyDescriptor in interface NiFiServiceFacadeid - idproperty - propertypublic ControllerServiceReferencingComponentsEntity getControllerServiceReferencingComponents(java.lang.String controllerServiceId)
NiFiServiceFacadegetControllerServiceReferencingComponents in interface NiFiServiceFacadecontrollerServiceId - idpublic java.util.Set<ReportingTaskEntity> getReportingTasks()
NiFiServiceFacadegetReportingTasks in interface NiFiServiceFacadepublic ReportingTaskEntity getReportingTask(java.lang.String reportingTaskId)
NiFiServiceFacadegetReportingTask in interface NiFiServiceFacadereportingTaskId - idpublic PropertyDescriptorDTO getReportingTaskPropertyDescriptor(java.lang.String id, java.lang.String property)
NiFiServiceFacadegetReportingTaskPropertyDescriptor in interface NiFiServiceFacadeid - idproperty - propertypublic StatusHistoryEntity getProcessGroupStatusHistory(java.lang.String groupId)
NiFiServiceFacadegetProcessGroupStatusHistory in interface NiFiServiceFacadegroupId - idpublic HistoryDTO getActions(HistoryQueryDTO historyQueryDto)
NiFiServiceFacadegetActions in interface NiFiServiceFacadehistoryQueryDto - querypublic ActionEntity getAction(java.lang.Integer actionId)
NiFiServiceFacadegetAction in interface NiFiServiceFacadeactionId - idpublic ComponentHistoryDTO getComponentHistory(java.lang.String componentId)
NiFiServiceFacadegetComponentHistory in interface NiFiServiceFacadecomponentId - idpublic boolean isClustered()
isClustered in interface NiFiServiceFacadepublic java.lang.String getNodeId()
getNodeId in interface NiFiServiceFacadepublic ClusterDTO getCluster()
getCluster in interface NiFiServiceFacadepublic NodeDTO getNode(java.lang.String nodeId)
NiFiServiceFacadegetNode in interface NiFiServiceFacadenodeId - a node identifierpublic void deleteNode(java.lang.String nodeId)
NiFiServiceFacadedeleteNode in interface NiFiServiceFacadenodeId - a node identifierpublic void setProperties(NiFiProperties properties)
public void setControllerFacade(ControllerFacade controllerFacade)
public void setRemoteProcessGroupDAO(RemoteProcessGroupDAO remoteProcessGroupDAO)
public void setLabelDAO(LabelDAO labelDAO)
public void setFunnelDAO(FunnelDAO funnelDAO)
public void setSnippetDAO(SnippetDAO snippetDAO)
public void setProcessorDAO(ProcessorDAO processorDAO)
public void setConnectionDAO(ConnectionDAO connectionDAO)
public void setAuditService(AuditService auditService)
public void setRevisionManager(RevisionManager revisionManager)
public void setDtoFactory(DtoFactory dtoFactory)
public void setEntityFactory(EntityFactory entityFactory)
public void setInputPortDAO(PortDAO inputPortDAO)
public void setOutputPortDAO(PortDAO outputPortDAO)
public void setProcessGroupDAO(ProcessGroupDAO processGroupDAO)
public void setControllerServiceDAO(ControllerServiceDAO controllerServiceDAO)
public void setReportingTaskDAO(ReportingTaskDAO reportingTaskDAO)
public void setTemplateDAO(TemplateDAO templateDAO)
public void setSnippetUtils(SnippetUtils snippetUtils)
public void setAuthorizableLookup(AuthorizableLookup authorizableLookup)
public void setAuthorizer(Authorizer authorizer)
public void setUserDAO(UserDAO userDAO)
public void setUserGroupDAO(UserGroupDAO userGroupDAO)
public void setAccessPolicyDAO(AccessPolicyDAO accessPolicyDAO)
public void setClusterCoordinator(ClusterCoordinator coordinator)
public void setHeartbeatMonitor(HeartbeatMonitor heartbeatMonitor)
public void setBulletinRepository(BulletinRepository bulletinRepository)
public void setLeaderElectionManager(LeaderElectionManager leaderElectionManager)