@Test
    public void testDynamicSinks() {
        Event event = new Event(eventQueues, parametersUtils, objectMapper);
        WorkflowModel workflow = new WorkflowModel();
        workflow.setWorkflowDefinition(testWorkflowDefinition);

        TaskModel task = new TaskModel();
        task.setReferenceTaskName("task0");
        task.setTaskId("task_id_0");
        task.setStatus(TaskModel.Status.IN_PROGRESS);
        task.getInputData().put("sink", "conductor:some_arbitary_queue");

        String queueName = event.computeQueueName(workflow, task);
        ObservableQueue queue = event.getQueue(queueName, task.getTaskId());
        assertEquals(TaskModel.Status.IN_PROGRESS, task.getStatus());
        assertNotNull(queue);
        assertEquals("testWorkflow:some_arbitary_queue", queue.getName());
        assertEquals("testWorkflow:some_arbitary_queue", queue.getURI());
        assertEquals("conductor", queue.getType());

        task.getInputData().put("sink", "conductor");
        queueName = event.computeQueueName(workflow, task);
        queue = event.getQueue(queueName, task.getTaskId());
        assertEquals(
                "not in progress: " + task.getReasonForIncompletion(),
                TaskModel.Status.IN_PROGRESS,
                task.getStatus());
        assertNotNull(queue);
        assertEquals("testWorkflow:task0", queue.getName());

        task.getInputData().put("sink", "sqs:my_sqs_queue_name");
        queueName = event.computeQueueName(workflow, task);
        queue = event.getQueue(queueName, task.getTaskId());
        assertEquals(
                "not in progress: " + task.getReasonForIncompletion(),
                TaskModel.Status.IN_PROGRESS,
                task.getStatus());
        assertNotNull(queue);
        assertEquals("my_sqs_queue_name", queue.getName());
        assertEquals("sqs", queue.getType());
    }
Tests the {@link Event#computeQueueName(WorkflowModel, TaskModel)} and {@link
Event#getQueue(String, String)} methods with a real {@link ParametersUtils} object.
core/src/test/java/com/netflix/conductor/core/execution/tasks/EventQueueResolutionTest.java