Index (Ikasan Flow Implementation Visitor Pattern 3.2.2 API)

A B C D E F G I L M N O P R S T U V _
All Classes All Packages

A

AbstractFlowConfiguration - Class in org.ikasan.flow.visitorPattern: Abstract implementation of a flow configuration
AbstractFlowConfiguration(FlowElement, ConfigurationService, ResubmissionService, ReplayRecordService) - Constructor for class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: Constructor
AbstractFlowElementInvoker<T> - Class in org.ikasan.flow.visitorPattern.invoker: An abstract implementation of the FlowElementInvoker
AbstractFlowElementInvoker(T) - Constructor for class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker: Constructor
addCustomMetric(String, String) - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
addElementInvocation(FlowElementInvocation) - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
addFlowListener(FlowEventListener) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Add a flow event listener
afterInvocation(FlowElement) - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
areContextListenersRunning() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow

B

beforeInvocation(FlowElement) - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
BrokerFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for brokers
BrokerFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.BrokerFlowElementInvoker

C

call() - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowElement
cancel() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory.ManagedResourceRecoveryManagerImpl
ClonerReplicationFactory<T> - Class in org.ikasan.flow.event: Implementation of the replicationFactory contract.
ClonerReplicationFactory(Cloner) - Constructor for class org.ikasan.flow.event.ClonerReplicationFactory: Constructor
combine(FlowInvocationContext) - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
ComponentTimingLoggingListener - Class in org.ikasan.flow.context: Simple Listener that will log the FlowInvocationContext component timing statistics
ComponentTimingLoggingListener() - Constructor for class org.ikasan.flow.context.ComponentTimingLoggingListener
ConcurrentSplitterFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a concurrent splitter This invokes a subFlow concurrently, using an ExecutorService, for each element of the resulting split, then continues with the main flow in the current thread
ConcurrentSplitterFlowElementInvoker(ExecutorService) - Constructor for class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker: Constructor
ConcurrentSplitterFlowElementInvoker.SplitFlowCallback - Class in org.ikasan.flow.visitorPattern.invoker
ConcurrentSplitterFlowElementInvoker.SplitFlowElement - Class in org.ikasan.flow.visitorPattern.invoker: Concurrent executions
ConcurrentSplitterInvokerConfiguration - Class in org.ikasan.flow.visitorPattern.invoker: Default Configuration options for Concurrent splitter invoker.
ConcurrentSplitterInvokerConfiguration() - Constructor for class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterInvokerConfiguration
configuration - Variable in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker: configuration instance
configurationService - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: handle to configuration service
configure(ConfiguredResource) - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
configuredReourceFlowElements - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: configured resources within the flow as depicted by the developer
configuredResourceId - Variable in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker: configuration id
ConsumerFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a consumer
ConsumerFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.ConsumerFlowElementInvoker: Constructor
ConverterFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a converter
ConverterFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.ConverterFlowElementInvoker: Constructor
count - Variable in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowCallback
createFlowInvocationContext() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Factory method for creating a flow invocation context.

D

DefaultExclusionFlowConfiguration - Class in org.ikasan.flow.visitorPattern: Default implementation of an Exclusion Flow Configuration
DefaultExclusionFlowConfiguration(FlowElement<?>, ConfigurationService, ResubmissionService, ReplayRecordService) - Constructor for class org.ikasan.flow.visitorPattern.DefaultExclusionFlowConfiguration: Constructor
DefaultFlowConfiguration - Class in org.ikasan.flow.visitorPattern: Default implementation of a Flow
DefaultFlowConfiguration(FlowElement<Consumer>, ConfigurationService, ResubmissionService, ReplayRecordService) - Constructor for class org.ikasan.flow.visitorPattern.DefaultFlowConfiguration: Constructor
DefaultFlowElementInvocation() - Constructor for class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
DefaultFlowInvocationContext - Class in org.ikasan.flow.visitorPattern: This class acts as a transfer object holding flow invocation time data relevant only to a single invocation of an Event down a Flow.
DefaultFlowInvocationContext() - Constructor for class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
DefaultReplicationFactory - Class in org.ikasan.flow.event: Implementation of the replicationFactory contract.
DefaultReplicationFactory() - Constructor for class org.ikasan.flow.event.DefaultReplicationFactory
destroy() - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker
dynamicConfiguredResourceFlowElements - Variable in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: handle to the dynamically configured resources within the flow.

E

endFlow(FlowInvocationContext) - Method in class org.ikasan.flow.context.ComponentTimingLoggingListener
endFlowInvocation() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
errorReportingServiceAwareFlowElements - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: errorReportingServiceAware resources within the flow
ExclusionFlowConfiguration - Interface in org.ikasan.flow.visitorPattern: Contract for an exclusion flow which handles events marked for exclusion from the normal business flow.

F

FilterFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a filter
FilterFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.FilterFlowElementInvoker: Constructor
filterInvokerConfiguration() - Static method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfigurationFactory: Getter factory method for creating and returning an instance of a MRR invoker configuration.
FilterInvokerConfiguration - Class in org.ikasan.flow.visitorPattern.invoker: Default FilterConfiguration bean common to all filters.
FilterInvokerConfiguration() - Constructor for class org.ikasan.flow.visitorPattern.invoker.FilterInvokerConfiguration
flowElementCaptureMetrics(FlowElement) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
FlowElementImpl<COMPONENT> - Class in org.ikasan.flow.visitorPattern: Simple implementation of FlowElement
FlowElementImpl(String, COMPONENT, FlowElementInvoker<COMPONENT>) - Constructor for class org.ikasan.flow.visitorPattern.FlowElementImpl: Overloaded constructor for a FlowElement with no downstream
FlowElementImpl(String, COMPONENT, FlowElementInvoker<COMPONENT>, Map<String, FlowElement>) - Constructor for class org.ikasan.flow.visitorPattern.FlowElementImpl: Constructor for when there are more than one subsequent FlowElements
FlowElementImpl(String, COMPONENT, FlowElementInvoker<COMPONENT>, FlowElement) - Constructor for class org.ikasan.flow.visitorPattern.FlowElementImpl: Overloaded constructor for when there is at most one subsequent FlowElement
FlowElementInvocationFactory - Class in org.ikasan.flow.event: Simple factory for creating FlowElementInvocation objects
FlowElementInvocationFactory.DefaultFlowElementInvocation - Class in org.ikasan.flow.event: Default implementation of the FlowElementInvocation
flowElementInvokerConfiguredResources - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: configured resources within the Ikasan framework space
FlowEventFactory - Class in org.ikasan.flow.event: Implementation of the EventFactory contract based on the creation of a FlowEvent.
FlowEventFactory() - Constructor for class org.ikasan.flow.event.FlowEventFactory
flowInvocationContext - Variable in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowCallback
flowInvocationContextListeners - Variable in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
FlowPersistentConfiguration - Class in org.ikasan.flow.configuration
FlowPersistentConfiguration() - Constructor for class org.ikasan.flow.configuration.FlowPersistentConfiguration

G

getAfterIdentifier() - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
getAfterRelatedIdentifier() - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
getAsConverter(Consumer) - Method in class org.ikasan.flow.visitorPattern.invoker.ConsumerFlowElementInvoker: method to aid testing
getBeforeIdentifier() - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
getBeforeRelatedIdentifier() - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
getCaptureMetrics() - Method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfiguration
getComponentName() - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl
getConcurrentThreads() - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterInvokerConfiguration
getConfiguration() - Method in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
getConfiguration() - Method in class org.ikasan.flow.visitorPattern.invoker.FilterFlowElementInvoker
getConfiguration() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
getConfiguredResourceFlowElements() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getConfiguredResourceFlowElements() - Method in interface org.ikasan.flow.visitorPattern.ExclusionFlowConfiguration
getConfiguredResourceId() - Method in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
getConfiguredResourceId() - Method in class org.ikasan.flow.visitorPattern.invoker.FilterFlowElementInvoker
getConfiguredResourceId() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
getConsumerFlowElement() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowConfiguration
getCustomMetrics() - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
getDescription() - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl
getDynamicConfiguredResourceFlowElements() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getDynamicConfiguredResourceFlowElements() - Method in interface org.ikasan.flow.visitorPattern.ExclusionFlowConfiguration
getElementInvocations() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
getEndTimeMillis() - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
getErrorReportingServiceAwareFlowElements() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getErrorReportingServiceAwareFlowElements() - Method in interface org.ikasan.flow.visitorPattern.ExclusionFlowConfiguration
getErrorUri() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
getFinalAction() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
getFlowComponent() - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl
getFlowConfiguration() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
getFlowElement() - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
getFlowElement(String) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Return the flow element matching this name.
getFlowElementInvoker() - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl: Getter for the flow element invoker
getFlowElementInvokerConfiguredResources() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getFlowElementInvokerConfiguredResources() - Method in interface org.ikasan.flow.visitorPattern.ExclusionFlowConfiguration
getFlowElements() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getFlowElements() - Method in interface org.ikasan.flow.visitorPattern.ExclusionFlowConfiguration
getFlowElements() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
getFlowEndTimeMillis() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
getFlowEventListeners() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Allow extention for testing.
getFlowInvocationContextListeners() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
getFlowStartTimeMillis() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
getInstance() - Static method in class org.ikasan.flow.event.DefaultReplicationFactory
getInvokeContextListeners() - Method in class org.ikasan.flow.configuration.FlowPersistentConfiguration
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.BrokerFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.ConsumerFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.ConverterFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.FilterFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.MultiRecipientRouterFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.ProducerFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.SequencerFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.SingleRecipientRouterFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterFlowElementInvoker
getInvokerType() - Method in class org.ikasan.flow.visitorPattern.invoker.TranslatorFlowElementInvoker
getIsRecording() - Method in class org.ikasan.flow.configuration.FlowPersistentConfiguration
getLastComponentName() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext: Accessor for the name of the last component invoked
getLeadFlowElement() - Method in class org.ikasan.flow.visitorPattern.DefaultExclusionFlowConfiguration
getLeadFlowElement() - Method in interface org.ikasan.flow.visitorPattern.ExclusionFlowConfiguration: Get the first (lead) flow element of the exclusion flow.
getManagedResourceFlowElements() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getManagedResourceFlowElements() - Method in interface org.ikasan.flow.visitorPattern.ExclusionFlowConfiguration
getManagedResourceRecoveryManager(String) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory: Get the named managed resource recovery manager
getManagedServices() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getModuleName() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Get this module name String moduleName
getName() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Get this flow name return name
getRecordedEventTimeToLive() - Method in class org.ikasan.flow.configuration.FlowPersistentConfiguration
getReplayRecordService() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getResubmissionService() - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration
getResubmissionService() - Method in interface org.ikasan.flow.visitorPattern.ExclusionFlowConfiguration
getSerialiserFactory() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
getSnapEvent() - Method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfiguration
getSplitEventTo() - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration
getStartTimeMillis() - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
getState() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Resolve the state of this flow into a string representation
getStopWaitTimeout() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Get the stop wait timeout
getTransition(String) - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl
getTransitions() - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl
getTriggerService() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow

I

ignoreContextInvocation - Variable in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
IndividualEvents - org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration.SplitEventTo
InvalidFlowException - Exception in org.ikasan.flow.visitorPattern: Exception representing an invalid Flow configuration
InvalidFlowException(String) - Constructor for exception org.ikasan.flow.visitorPattern.InvalidFlowException: Constructor
invoke(String, String, FlowInvocationContext, FlowEvent, FlowElement) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
invoke(Throwable) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Invoke the recover manager to act on the passed exception.
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Broker>) - Method in class org.ikasan.flow.visitorPattern.invoker.BrokerFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Consumer>) - Method in class org.ikasan.flow.visitorPattern.invoker.ConsumerFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Producer>) - Method in class org.ikasan.flow.visitorPattern.invoker.ProducerFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Filter>) - Method in class org.ikasan.flow.visitorPattern.invoker.FilterFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<MultiRecipientRouter>) - Method in class org.ikasan.flow.visitorPattern.invoker.MultiRecipientRouterFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<SingleRecipientRouter>) - Method in class org.ikasan.flow.visitorPattern.invoker.SingleRecipientRouterFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Sequencer>) - Method in class org.ikasan.flow.visitorPattern.invoker.SequencerFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Splitter>) - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Splitter>) - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Converter>) - Method in class org.ikasan.flow.visitorPattern.invoker.ConverterFlowElementInvoker
invoke(List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent, FlowElement<Translator>) - Method in class org.ikasan.flow.visitorPattern.invoker.TranslatorFlowElementInvoker
invoke(Resubmission<FlowEvent<?, ?>>) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
invoke(FlowEvent<?, ?>) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Invoke the flow with a flow event
invokeContextListeners - Variable in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker: flag to control invocation of the context listeners at runtime, defaults to true
invokeContextListeners - Variable in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: flag to control invocation of the context listeners at runtime, defaults to true
InvokerConfiguration - Class in org.ikasan.flow.visitorPattern.invoker: Default FilterConfiguration bean common to all filters.
InvokerConfiguration() - Constructor for class org.ikasan.flow.visitorPattern.invoker.InvokerConfiguration
InvokerConfigurationFactory - Class in org.ikasan.flow.visitorPattern.invoker: Ikasan Invoker Configuration Factory for generating flow element invoker configurations.
InvokerConfigurationFactory() - Constructor for class org.ikasan.flow.visitorPattern.invoker.InvokerConfigurationFactory
isApplyFilter() - Method in class org.ikasan.flow.visitorPattern.invoker.FilterInvokerConfiguration: Getter for determining if filter should be applied
isApplyTranslator() - Method in class org.ikasan.flow.visitorPattern.invoker.TranslatorInvokerConfiguration
isCloneEventPerRoute() - Method in class org.ikasan.flow.visitorPattern.invoker.MultiRecipientRouterInvokerConfiguration: Is the event to be cloned for each route out of the multi-recipient router
isDynamicConfiguration() - Method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfiguration
isLogFiltered() - Method in class org.ikasan.flow.visitorPattern.invoker.FilterInvokerConfiguration
isPaused() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Is this flow in a paused state
isRecovering() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory.ManagedResourceRecoveryManagerImpl
isRunning() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Is this flow in a running / recovering state
isSendSplitsAsSinglePayload() - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterInvokerConfiguration
isSplitEventToIndividualEvents() - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration
isSplitEventToListOfEvents() - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration
isSplitEventToListOfPayloads() - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration

L

leadFlowElement - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: handle on the lead flow element
ListOfEvents - org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration.SplitEventTo
ListOfPayloads - org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration.SplitEventTo
logger - Static variable in class org.ikasan.flow.context.ComponentTimingLoggingListener

M

managedReourceFlowElements - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: managed resources within the flow
ManagedResourceRecoveryManagerFactory() - Constructor for class org.ikasan.flow.visitorPattern.VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory
ManagedResourceRecoveryManagerImpl(String) - Constructor for class org.ikasan.flow.visitorPattern.VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory.ManagedResourceRecoveryManagerImpl: Constructor
managedServices - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: managed services within the flow
MultiRecipientRouterFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a multi-recipient router
MultiRecipientRouterFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.MultiRecipientRouterFlowElementInvoker: Constructor
MultiRecipientRouterFlowElementInvoker(ReplicationFactory<FlowEvent<?, ?>>, MultiRecipientRouterInvokerConfiguration) - Constructor for class org.ikasan.flow.visitorPattern.invoker.MultiRecipientRouterFlowElementInvoker: Constructor
multiRecipientRouterInvokerConfiguration() - Static method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfigurationFactory: Getter factory method for creating and returning an instance of a MRR invoker configuration.
MultiRecipientRouterInvokerConfiguration - Class in org.ikasan.flow.visitorPattern.invoker: Multi-Recipient Router Invoker Configuration
MultiRecipientRouterInvokerConfiguration() - Constructor for class org.ikasan.flow.visitorPattern.invoker.MultiRecipientRouterInvokerConfiguration

N

newAsyncTask(FlowElement, List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent) - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker: Factory method to aid testing.
newEvent(IDENTIFIER, IDENTIFIER, long, PAYLOAD) - Method in class org.ikasan.flow.event.FlowEventFactory
newEvent(IDENTIFIER, IDENTIFIER, PAYLOAD) - Method in class org.ikasan.flow.event.FlowEventFactory
newEvent(IDENTIFIER, PAYLOAD) - Method in class org.ikasan.flow.event.FlowEventFactory: Factory method to create a new FlowEvent instance.
newInvocation() - Static method in class org.ikasan.flow.event.FlowElementInvocationFactory: Returns a new FlowElementInvocation object
newResubmissionEvent(EVENT) - Method in class org.ikasan.flow.event.ResubmissionEventFactoryImpl
notifyFlowInvocationContextListenersEndFlow(FlowInvocationContext) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Notify any FlowInvocationContextListeners that the flow has completed
notifyFlowInvocationContextListenersSnapEvent(FlowElement, FlowEvent) - Method in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker: Notify any FlowInvocationContextListeners that to snap an event
notifyMonitor() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Notification to all registered MonitorListener of the current state of the Initiator

O

onFailure(Throwable) - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowCallback
onSuccess(ConcurrentSplitterFlowElementInvoker.SplitFlowElement) - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowCallback
org.ikasan.flow.configuration - package org.ikasan.flow.configuration
org.ikasan.flow.context - package org.ikasan.flow.context
org.ikasan.flow.event - package org.ikasan.flow.event
org.ikasan.flow.visitorPattern - package org.ikasan.flow.visitorPattern
org.ikasan.flow.visitorPattern.invoker - package org.ikasan.flow.visitorPattern.invoker

P

pause() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
pendingCallback(List, AtomicInteger) - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker: Allows for easier testing
ProducerFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a producer
ProducerFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.ProducerFlowElementInvoker: Constructor

R

recover(Throwable) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory.ManagedResourceRecoveryManagerImpl
removeFlowListener(FlowEventListener) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Remove a flow event listener
replayRecordService - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: handle to the replay service
replicate(T) - Method in class org.ikasan.flow.event.ClonerReplicationFactory: Return a completely independent deep copy instance of the incoming object.
ResubmissionEventFactoryImpl - Class in org.ikasan.flow.event
ResubmissionEventFactoryImpl() - Constructor for class org.ikasan.flow.event.ResubmissionEventFactoryImpl
resubmissionService - Variable in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration: handle to the re-submission service
resume() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow

S

SequencerFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a sequencer
SequencerFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.SequencerFlowElementInvoker: Constructor
setAfterIdentifier(Object) - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
setAfterRelatedIdentifier(Object) - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
setApplyFilter(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.FilterInvokerConfiguration: Setter for determining if the filter should be applied
setApplyTranslator(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.TranslatorInvokerConfiguration
setBeforeIdentifier(Object) - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
setBeforeRelatedIdentifier(Object) - Method in class org.ikasan.flow.event.FlowElementInvocationFactory.DefaultFlowElementInvocation
setCaptureMetrics(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfiguration
setCloneEventPerRoute(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.MultiRecipientRouterInvokerConfiguration: Set whether or not the event should be cloned for each route out of the multi-recipient router.
setConcurrentThreads(int) - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterInvokerConfiguration
setConfiguration(FlowPersistentConfiguration) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
setConfiguration(FilterInvokerConfiguration) - Method in class org.ikasan.flow.visitorPattern.invoker.FilterFlowElementInvoker
setConfiguration(T) - Method in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
setConfiguredResourceId(String) - Method in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
setConfiguredResourceId(String) - Method in class org.ikasan.flow.visitorPattern.invoker.FilterFlowElementInvoker
setConfiguredResourceId(String) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
setDescription(String) - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl: Setter for description
setDynamicConfiguration(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfiguration
setErrorReportingService(ErrorReportingService) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
setErrorUri(String) - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
setFinalAction(FinalAction) - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
setFlowElementInvoker(FlowElementInvoker<COMPONENT>) - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl: Setter for the flow element invoker
setFlowInvocationContextListeners(List<FlowInvocationContextListener>) - Method in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
setFlowInvocationContextListeners(List<FlowInvocationContextListener>) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
setFlowListener(FlowEventListener) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Replace existing flow event listeners with this flow event listener.
setIgnoreContextInvocation(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
setInvokeContextListeners(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.AbstractFlowElementInvoker
setInvokeContextListeners(Boolean) - Method in class org.ikasan.flow.configuration.FlowPersistentConfiguration
setIsRecording(Boolean) - Method in class org.ikasan.flow.configuration.FlowPersistentConfiguration
setLastComponentName(String) - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
setLogFiltered(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.FilterInvokerConfiguration
setManagedResourceRecoveryManagerFactory(VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Allow override of the managed resource recovery manager within this class.
setMonitor(Monitor) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Set the flow monitor
setRecordedEventTimeToLive(Integer) - Method in class org.ikasan.flow.configuration.FlowPersistentConfiguration
setSendSplitsAsSinglePayload(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterInvokerConfiguration
setSnapEvent(boolean) - Method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfiguration
setSplitEventTo(SplitterInvokerConfiguration.SplitEventTo) - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration
setSplitEventToIndividualEvents() - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration
setSplitEventToListOfEvents() - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration
setSplitEventToListOfPayloads() - Method in class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration
setStopWaitTimeout(long) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Set the stop wait timeout
setTriggerService(TriggerService) - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
shallowReplicate(T) - Method in class org.ikasan.flow.event.ClonerReplicationFactory: Return a completely independent shallow copy instance of the incoming object.
SingleRecipientRouterFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a singleRecipientRouter
SingleRecipientRouterFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.SingleRecipientRouterFlowElementInvoker: Constructor
snapEvent(FlowElement, FlowEvent) - Method in class org.ikasan.flow.context.ComponentTimingLoggingListener
SplitFlowCallback(List<Object>, FlowInvocationContext, AtomicInteger) - Constructor for class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowCallback
SplitFlowElement(FlowElement, List<FlowEventListener>, String, String, FlowInvocationContext, FlowEvent) - Constructor for class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowElement
SplitterFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a splitter
SplitterFlowElementInvoker(EventFactory<FlowEvent<?, ?>>) - Constructor for class org.ikasan.flow.visitorPattern.invoker.SplitterFlowElementInvoker: Constructor
splitterInvokerConfiguration() - Static method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfigurationFactory: Getter factory method for creating and returning an instance of a splitter invoker configuration.
SplitterInvokerConfiguration - Class in org.ikasan.flow.visitorPattern.invoker: Default Configuration options for Splitter invoker.
SplitterInvokerConfiguration() - Constructor for class org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration
SplitterInvokerConfiguration.SplitEventTo - Enum in org.ikasan.flow.visitorPattern.invoker
start() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Start this flow
startConsumer() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Start the consumer component.
startContextListeners() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
startFlowInvocation() - Method in class org.ikasan.flow.visitorPattern.DefaultFlowInvocationContext
startManagedResources() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Start the components marked as including Managed Resources.
startPause() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
stop() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Stop this flow
stopContextListeners() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow
stopManagedResources() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Stop all managed resources from left to right.
subFlowPayloads - Variable in class org.ikasan.flow.visitorPattern.invoker.ConcurrentSplitterFlowElementInvoker.SplitFlowCallback

T

toString() - Method in class org.ikasan.flow.visitorPattern.FlowElementImpl
TranslatorFlowElementInvoker - Class in org.ikasan.flow.visitorPattern.invoker: A default implementation of the FlowElementInvoker for a translator
TranslatorFlowElementInvoker() - Constructor for class org.ikasan.flow.visitorPattern.invoker.TranslatorFlowElementInvoker: Constructor
translatorInvokerConfiguration() - Static method in class org.ikasan.flow.visitorPattern.invoker.InvokerConfigurationFactory: Getter factory method for creating and returning an instance of a splitter invoker configuration.
TranslatorInvokerConfiguration - Class in org.ikasan.flow.visitorPattern.invoker: Default Configration options common to all invokers.
TranslatorInvokerConfiguration() - Constructor for class org.ikasan.flow.visitorPattern.invoker.TranslatorInvokerConfiguration

U

update(ConfiguredResource) - Method in class org.ikasan.flow.visitorPattern.AbstractFlowConfiguration

V

valueOf(String) - Static method in enum org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration.SplitEventTo: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.ikasan.flow.visitorPattern.invoker.SplitterInvokerConfiguration.SplitEventTo: Returns an array containing the constants of this enum type, in the order they are declared.
VisitingInvokerFlow<ID> - Class in org.ikasan.flow.visitorPattern: Default implementation of a Flow
VisitingInvokerFlow(String, String, FlowConfiguration, ExclusionFlowConfiguration, RecoveryManager<FlowEvent<?, ?>, FlowInvocationContext, ID>, ExclusionService, SerialiserFactory) - Constructor for class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Constructor
VisitingInvokerFlow(String, String, FlowConfiguration, RecoveryManager<FlowEvent<?, ?>, FlowInvocationContext, ID>, ExclusionService, SerialiserFactory) - Constructor for class org.ikasan.flow.visitorPattern.VisitingInvokerFlow: Constructor
VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory - Class in org.ikasan.flow.visitorPattern: Managed Resource Recovery Manager factory used to create MR recovery manager instances per named managed resource.
VisitingInvokerFlow.ManagedResourceRecoveryManagerFactory.ManagedResourceRecoveryManagerImpl - Class in org.ikasan.flow.visitorPattern: Managed Resource Recovery Manager implementation

_

_start() - Method in class org.ikasan.flow.visitorPattern.VisitingInvokerFlow

A B C D E F G I L M N O P R S T U V _
All Classes All Packages