SystemTaskWorkerCoordinator { @VisibleForTesting boolean isFromCoordinatorExecutionNameSpace(String queueName) { String queueExecutionNameSpace = QueueUtils.getExecutionNameSpace(queueName); return StringUtils.equals(queueExecutionNameSpace, executionNameSpace); } @Inject  SystemTaskWorkerCoordinator(QueueDAO queueDAO, WorkflowExecutor workflowExecutor, Configuration config, ExecutionService executionService);  static Map<String, WorkflowSystemTask> taskNameWorkflowTaskMapping; }
@Test public void testIsFromCoordinatorExecutionNameSpace() { System.setProperty("workflow.system.task.worker.executionNameSpace", "exeNS"); Configuration configuration = new SystemPropertiesConfiguration(); SystemTaskWorkerCoordinator systemTaskWorkerCoordinator = new SystemTaskWorkerCoordinator(queueDAO, workflowExecutor, configuration, executionService); assertTrue(systemTaskWorkerCoordinator.isFromCoordinatorExecutionNameSpace(TEST_QUEUE + EXECUTION_NAMESPACE_CONSTANT)); }