private static RegisterActivityTypeRequest buildRegisterActivityTypeRequest()

in src/main/java/com/amazonaws/services/simpleworkflow/flow/worker/GenericActivityWorker.java [130:157]

27 lines of code
6 McCabe index (conditional complexity)


    private static RegisterActivityTypeRequest buildRegisterActivityTypeRequest(String domain, ActivityType activityType,
            ActivityTypeRegistrationOptions registrationOptions, String taskListToPoll) throws AwsServiceException {
        RegisterActivityTypeRequest.Builder registerActivityBuilder = RegisterActivityTypeRequest.builder().domain(domain);
        String taskList = registrationOptions.getDefaultTaskList();
        if (taskList == null) {
            taskList = taskListToPoll;
        } else if (taskList.equals(FlowConstants.NO_DEFAULT_TASK_LIST)) {
            taskList = null;
        }
        if (taskList != null && !taskList.isEmpty()) {
            registerActivityBuilder.defaultTaskList(TaskList.builder().name(taskList).build());
        }
        registerActivityBuilder
            .name(activityType.getName())
            .version(activityType.getVersion())
            .defaultTaskStartToCloseTimeout(FlowHelpers.secondsToDuration(registrationOptions.getDefaultTaskStartToCloseTimeoutSeconds()))
            .defaultTaskScheduleToCloseTimeout(
                FlowHelpers.secondsToDuration(registrationOptions.getDefaultTaskScheduleToCloseTimeoutSeconds()))
            .defaultTaskHeartbeatTimeout(FlowHelpers.secondsToDuration(registrationOptions.getDefaultTaskHeartbeatTimeoutSeconds()))
            .defaultTaskScheduleToStartTimeout(
                FlowHelpers.secondsToDuration(registrationOptions.getDefaultTaskScheduleToStartTimeoutSeconds()))
            .defaultTaskPriority(FlowHelpers.taskPriorityToString(registrationOptions.getDefaultTaskPriority()));

        if (registrationOptions.getDescription() != null) {
            registerActivityBuilder.description(registrationOptions.getDescription());
        }
        return registerActivityBuilder.build();
    }