|
Class Summary |
| DefaultSynapse<S,A> |
Default synapse implementation. |
| DelegatingPolicy |
Delegates execution to another executor, e.g. |
| ExecutorSynapseFactory<K,S,A> |
This synapse factory creates invocation tasks and passes them to executor. |
| FlowBase<N extends Node<P,K,S,A>,T extends Transition<S,A>,P,K,S,A> |
Base class for flow implementations. |
| Joiner<T,C,R> |
Helper class to join data from several inputs. |
| Joiner.InputConsumer |
Interface to consume inputs in join() method. |
| MapPropertySet |
Creates property sets backed by ConcurrentHashMap. |
| MapPropertySetFactory |
Creates map property sets. |
| PassThroughNode<P,K,S,A> |
Transition which doesn't do any processing - it simply passes invocation from source to targets. |
| PassThroughTransition<S,A> |
Transition which doesn't do any processing - it simply passes invocation from source to target. |
| ProcessingPathElementImpl |
Implementation of processing path element. |
| PropertySetMap |
Map backed by property set. |
| PropertySubSet |
Property set backed by another (master) and operating
only on properties with names starting with specified prefix. |
| TaskCountingFlowBase<N extends Node<P,K,S,A>,T extends Transition<S,A>,P,K,S,A> |
Flow which counts processing tasks and has join() method to wait till all tasks finish. |
| ThreadInvocation |
Sets and un-sets thread invocation. |