flux-testutils/src/main/java/software/amazon/aws/clients/swf/flux/testutil/StubFluxCapacitor.java [123:147]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        WorkflowExecutionRecord execution = new WorkflowExecutionRecord(workflowType, expectedWorkflowId);
        if (!executedWorkflows.containsKey(execution)) {
            throw new RuntimeException(String.format("No %s execution request for %s was found.",
                                                     TaskNaming.workflowName(workflowType), expectedWorkflowId));
        }
        if (expectedInput == null && !executedWorkflows.get(execution).isEmpty()) {
            throw new RuntimeException(String.format("%s execution %s should have had empty input but instead had %s",
                                                     TaskNaming.workflowName(workflowType), expectedWorkflowId,
                                                     StepAttributes.encode(executedWorkflows.get(execution))));
        }
        if (!executedWorkflows.get(execution).equals(expectedInput)) {
            throw new RuntimeException(String.format("%s execution %s should have had input %s but instead had %s",
                                                     TaskNaming.workflowName(workflowType), expectedWorkflowId,
                                                     StepAttributes.encode(expectedInput),
                                                     StepAttributes.encode(executedWorkflows.get(execution))));
        }
    }

    /**
     * Utility method allowing unit tests to verify that a workflow was *not* executed with the specified id.
     * @param workflowType - The type of workflow that should not have been executed
     * @param workflowId   - The id of the workflow that should not have been executed
     */
    public void verifyWorkflowWasNotStarted(Class<? extends Workflow> workflowType, String workflowId) {
        WorkflowExecutionRecord execution = new WorkflowExecutionRecord(workflowType, workflowId);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flux-testutils/src/main/java/software/amazon/aws/clients/swf/flux/testutil/StubRemoteWorkflowExecutor.java [67:91]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        WorkflowExecutionRecord execution = new WorkflowExecutionRecord(workflowType, expectedWorkflowId);
        if (!executedWorkflows.containsKey(execution)) {
            throw new RuntimeException(String.format("No %s execution request for %s was found.",
                                                     TaskNaming.workflowName(workflowType), expectedWorkflowId));
        }
        if (expectedInput == null && !executedWorkflows.get(execution).isEmpty()) {
            throw new RuntimeException(String.format("%s execution %s should have had empty input but instead had %s",
                                                     TaskNaming.workflowName(workflowType), expectedWorkflowId,
                                                     StepAttributes.encode(executedWorkflows.get(execution))));
        }
        if (!executedWorkflows.get(execution).equals(expectedInput)) {
            throw new RuntimeException(String.format("%s execution %s should have had input %s but instead had %s",
                                                     TaskNaming.workflowName(workflowType), expectedWorkflowId,
                                                     StepAttributes.encode(expectedInput),
                                                     StepAttributes.encode(executedWorkflows.get(execution))));
        }
    }

    /**
     * Utility method allowing unit tests to verify that a workflow was *not* executed with the specified id.
     * @param workflowType - The type of workflow that should not have been executed
     * @param workflowId   - The id of the workflow that should not have been executed
     */
    public void verifyWorkflowWasNotStarted(Class<? extends Workflow> workflowType, String workflowId) {
        WorkflowExecutionRecord execution = new WorkflowExecutionRecord(workflowType, workflowId);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -