@Override public ActivityImplementation getActivityImplementation(ActivityType activityType) { ActivityTypeExecutionOptions activityTypeExecutionOptions = configuration.getActivityTypeExecutionOptions() != null ? configuration.getActivityTypeExecutionOptions() : new ActivityTypeExecutionOptions(); ActivityTypeRegistrationOptions activityTypeRegistrationOptions = configuration.getActivityTypeRegistrationOptions() != null ? configuration.getActivityTypeRegistrationOptions() : new ActivityTypeRegistrationOptions(); DataConverter dataConverter = configuration.getDataConverter() != null ? configuration.getDataConverter() : new JsonDataConverter(); return new CamelActivityImplementation(swfWorkflowConsumer, activityTypeRegistrationOptions, activityTypeExecutionOptions, dataConverter); }
@Override public WorkflowDefinitionFactory getWorkflowDefinitionFactory(WorkflowType workflowType) { WorkflowTypeRegistrationOptions registrationOptions = configuration.getWorkflowTypeRegistrationOptions() != null ? configuration.getWorkflowTypeRegistrationOptions() : new WorkflowTypeRegistrationOptions(); DataConverter dataConverter = configuration.getDataConverter() != null ? configuration.getDataConverter() : new JsonDataConverter(); return new CamelWorkflowDefinitionFactory(swfWorkflowConsumer, workflowType, registrationOptions, dataConverter); }