org.ikasan.builder

Class FlowBuilder

java.lang.Object

org.ikasan.builder.FlowBuilder

public class FlowBuilder
extends Object

A simple Flow builder.

Author:

Ikasan Development Team

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	FlowBuilder.FlowConfigurationBuilder ///////////////////////////////////////////////////////////////////////// ////////////////////////////////////// Class for wiring the components together

Constructor Summary

Constructors

Constructor and Description
FlowBuilder(String name, String moduleName) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
FlowBuilder.FlowConfigurationBuilder	consumer(String name, org.ikasan.spec.component.endpoint.Consumer consumer) Add a consumer
static FlowBuilder	newFlow(String name, String moduleName) Get a flow builder
void	setExceptionResolver(org.ikasan.exceptionResolver.ExceptionResolver exceptionResolver) Setter for exception resolver to be registered with the recovery manager.
void	setMonitor(org.ikasan.spec.monitor.Monitor monitor) Setter for monitor
void	setResubmissionService(org.ikasan.spec.resubmission.ResubmissionService resubmissionService) Setter for re-submission service
FlowBuilder	withConfigurationService(org.ikasan.spec.configuration.ConfigurationService configurationService) Allow override of default configuration service
FlowBuilder	withDescription(String description) Add a flow description
FlowBuilder	withErrorReportingService(org.ikasan.spec.error.reporting.ErrorReportingService errorReportingService) Override the default error reporting service
FlowBuilder	withEventFactory(org.ikasan.spec.event.EventFactory eventFactory) Override the default event factory
FlowBuilder	withExclusionFlowHeadElement(org.ikasan.spec.flow.FlowElement<?> exclusionFlowHeadElement) Setter for exclusion flow head flow element
FlowBuilder	withExclusionService(org.ikasan.spec.exclusion.ExclusionService exclusionService) Override the default exclusion service
FlowBuilder	withExclusionServiceFactory(org.ikasan.exclusion.service.ExclusionServiceFactory exclusionServiceFactory) Override the default exclusion service factory
FlowBuilder	withFlowInvocationContextListener(org.ikasan.spec.flow.FlowInvocationContextListener flowInvocationContextListener) Add in a FlowInvocationContextListener
FlowBuilder	withFlowInvocationContextListeners(List<org.ikasan.spec.flow.FlowInvocationContextListener> flowInvocationContextListeners) Set the full list of FlowInvocationContextListeners
FlowBuilder	withFlowListener(org.ikasan.spec.flow.FlowEventListener flowEventListener) Add a flow description
FlowBuilder	withRecoveryManager(org.ikasan.spec.recovery.RecoveryManager recoveryManager) Override the default recovery manager
FlowBuilder	withReplayRecordService(org.ikasan.spec.replay.ReplayRecordService replayRecordService)
FlowBuilder	withSerialiserFactory(org.ikasan.spec.serialiser.SerialiserFactory serialiserFactory)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlowBuilder

public FlowBuilder(String name,
           String moduleName)

Constructor

Parameters:

name -

Method Detail

newFlow

public static FlowBuilder newFlow(String name,
                  String moduleName)

Get a flow builder

Parameters:

name -

Returns:

withDescription

public FlowBuilder withDescription(String description)

Add a flow description

Parameters:

description -

Returns:

withFlowListener

public FlowBuilder withFlowListener(org.ikasan.spec.flow.FlowEventListener flowEventListener)

Add a flow description

Parameters:

flowEventListener -

Returns:

withConfigurationService

public FlowBuilder withConfigurationService(org.ikasan.spec.configuration.ConfigurationService configurationService)

Allow override of default configuration service

Parameters:

configurationService -

Returns:

withRecoveryManager

public FlowBuilder withRecoveryManager(org.ikasan.spec.recovery.RecoveryManager recoveryManager)

Override the default recovery manager

Parameters:

recoveryManager -

Returns:

withExclusionService

public FlowBuilder withExclusionService(org.ikasan.spec.exclusion.ExclusionService exclusionService)

Override the default exclusion service

Parameters:

exclusionService -

Returns:

withExclusionServiceFactory

public FlowBuilder withExclusionServiceFactory(org.ikasan.exclusion.service.ExclusionServiceFactory exclusionServiceFactory)

Override the default exclusion service factory

Parameters:

exclusionServiceFactory -

Returns:

withErrorReportingService

public FlowBuilder withErrorReportingService(org.ikasan.spec.error.reporting.ErrorReportingService errorReportingService)

Override the default error reporting service

Parameters:

errorReportingService -

Returns:

withExclusionFlowHeadElement

public FlowBuilder withExclusionFlowHeadElement(org.ikasan.spec.flow.FlowElement<?> exclusionFlowHeadElement)

Setter for exclusion flow head flow element

Parameters:

exclusionFlowHeadElement -

withSerialiserFactory

public FlowBuilder withSerialiserFactory(org.ikasan.spec.serialiser.SerialiserFactory serialiserFactory)

Parameters:

serialiserFactory - the ikasanSerialiserFactory to set

withFlowInvocationContextListener

public FlowBuilder withFlowInvocationContextListener(org.ikasan.spec.flow.FlowInvocationContextListener flowInvocationContextListener)

Add in a FlowInvocationContextListener

Parameters:

flowInvocationContextListener -

Returns:

the current builder

withFlowInvocationContextListeners

public FlowBuilder withFlowInvocationContextListeners(List<org.ikasan.spec.flow.FlowInvocationContextListener> flowInvocationContextListeners)

Set the full list of FlowInvocationContextListeners

Parameters:

flowInvocationContextListeners -

Returns:

the current builder

setMonitor

public void setMonitor(org.ikasan.spec.monitor.Monitor monitor)

Setter for monitor

Parameters:

monitor -

setResubmissionService

public void setResubmissionService(org.ikasan.spec.resubmission.ResubmissionService resubmissionService)

Setter for re-submission service

Parameters:

resubmissionService -

withReplayRecordService

public FlowBuilder withReplayRecordService(org.ikasan.spec.replay.ReplayRecordService replayRecordService)

Parameters:

replayRecordService - the replayRecordService to set

setExceptionResolver

public void setExceptionResolver(org.ikasan.exceptionResolver.ExceptionResolver exceptionResolver)

Setter for exception resolver to be registered with the recovery manager.

Parameters:

exceptionResolver -

withEventFactory

public FlowBuilder withEventFactory(org.ikasan.spec.event.EventFactory eventFactory)

Override the default event factory

Parameters:

eventFactory -

Returns:

consumer

public FlowBuilder.FlowConfigurationBuilder consumer(String name,
                                            org.ikasan.spec.component.endpoint.Consumer consumer)

Add a consumer

Parameters:

name -

consumer -

Returns: