org.oddjob.beanbus.destinations

Class SplitDestinations<T>

java.lang.Object

org.oddjob.framework.extend.BaseComponent

org.oddjob.framework.extend.BasePrimary

org.oddjob.framework.extend.StructuralJob<java.lang.Object>

org.oddjob.beanbus.destinations.SplitDestinations<T>

All Implemented Interfaces:

java.io.Flushable, java.io.Serializable, java.lang.Runnable, java.util.function.Consumer<T>, ArooaContextAware, ArooaSessionAware, Forceable, PropertyChangeNotifier, Transient, Iconic, LogEnabled, Resettable, Stateful, Stoppable, Structural

public class SplitDestinations<T>
extends StructuralJob<java.lang.Object>
implements Transient, java.util.function.Consumer<T>, java.io.Flushable

Description

A Bean Bus Destination that splits data between child destinations depending on a Strategy.

Example

All numbers are passed to two queues for computation of the Fibonacci Sequence of the number, and the Factorial.

<oddjob>
    <job>
        <sequential>
            <jobs>
                <script id="funcs">function fibonacci(x) {
	if (x&lt;1) return new java.lang.Integer(0)
	if (x==1) return new java.lang.Integer(1)
	return new java.lang.Integer(fibonacci(x-1) + fibonacci(x-2))
}

function factorial(x) {
	if (x&lt;1) return new java.lang.Integer(0)
	if (x==1) return new java.lang.Integer(1)
	return new java.lang.Integer(factorial(x-1) *x)
}

</script>
                <parallel id="parallel">
                    <jobs>
                        <bus:bus name="Fibonacci Bus" xmlns:bus="oddjob:beanbus">
                            <of>
                                <bus:driver>
                                    <values>
                                        <value value="${fibonacciQueue}"/>
                                    </values>
                                </bus:driver>
                                <bus:map name="Fibonacci">
                                    <function>
                                        <value value="${funcs.function(fibonacci)}"/>
                                    </function>
                                </bus:map>
                                <bus:collect id="fibonacci"/>
                            </of>
                        </bus:bus>
                        <bus:bus name="Factorial Bus" xmlns:bus="oddjob:beanbus">
                            <of>
                                <bus:driver>
                                    <values>
                                        <value value="${factorialQueue}"/>
                                    </values>
                                </bus:driver>
                                <bus:map name="Factorial">
                                    <function>
                                        <value value="${funcs.function(factorial)}"/>
                                    </function>
                                </bus:map>
                                <bus:collect id="factorial"/>
                            </of>
                        </bus:bus>
                        <bus:bus xmlns:bus="oddjob:beanbus">
                            <of>
                                <bus:driver>
                                    <values>
                                        <sequence from="1" to="5"/>
                                    </values>
                                </bus:driver>
                                <bean class="org.oddjob.beanbus.destinations.SplitDestinations">
                                    <strategy>
                                        <bean class="org.oddjob.beanbus.destinations.SplitDestinations$All"/>
                                    </strategy>
                                    <of>
                                        <bus:queue id="fibonacciQueue" name="FibonacciQueue"/>
                                        <bus:queue id="factorialQueue" name="FactorialQueue"/>
                                    </of>
                                </bean>
                            </of>
                        </bus:bus>
                    </jobs>
                </parallel>
                <folder name="Test the Funcs">
                    <jobs>
                        <echo name="Test Fibonacci">#{funcs.getFunction('fibonacci').apply(3)}</echo>
                        <echo name="Test Factorial">#{funcs.getFunction('factorial').apply(6)}</echo>
                    </jobs>
                </folder>
            </jobs>
        </sequential>
    </job>
</oddjob>

See Also:

Serialized Form

Author:

Rob Gordon

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SplitDestinations.All<T>
static class	SplitDestinations.Each<T>

Field Summary

Fields inherited from class org.oddjob.framework.extend.StructuralJob

childHelper, destroy, stop, structuralState

Constructor Summary

Constructors

Constructor and Description
SplitDestinations()

Method Summary

Modifier and Type	Method and Description
void	accept(T t)
protected void	execute() Execute this job.
void	flush()
java.util.concurrent.atomic.AtomicInteger	getCount()
protected StateOperator	getInitialStateOp() Subclasses must provide the StateOperator that will decide how to evaluate the children's state.
java.util.function.Function<? super java.util.function.Consumer<? super T>[],? extends java.util.function.Consumer<T>>	getStrategy()
protected void	onReset() Allow sub classes to do something on reset.
void	setOf(int index, java.lang.Object child) Add a child.
void	setStrategy(java.util.function.Function<? super java.util.function.Consumer<? super T>[],? extends java.util.function.Consumer<T>> strategy)

Methods inherited from class org.oddjob.framework.extend.StructuralJob

addStructuralListener, fireDestroyedState, force, getStateChanger, hardReset, iconHelper, isStop, onDestroy, onHardReset, onSoftReset, onStop, postStop, removeStructuralListener, run, softReset, startChildStateReflector, stateHandler, stop, stopChildStateReflector, waitForChildrenOnStop

Methods inherited from class org.oddjob.framework.extend.BasePrimary

configure, getName, logger, logger, loggerName, save, setName, toString

Methods inherited from class org.oddjob.framework.extend.BaseComponent

addIconListener, addPropertyChangeListener, addStateListener, configure, destroy, firePropertyChange, getArooaSession, iconForId, initialise, lastStateEvent, onConfigured, onInitialised, removeIconListener, removePropertyChangeListener, removeStateListener, save, setArooaContext, setArooaSession

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Consumer

andThen

Methods inherited from interface org.oddjob.Stateful

addStateListener, lastStateEvent, removeStateListener

Constructor Detail

SplitDestinations

public SplitDestinations()

Method Detail

execute

protected void execute()
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException

Description copied from class: StructuralJob

Execute this job.

Specified by:

execute in class StructuralJob<java.lang.Object>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

accept

public void accept(T t)

Specified by:

accept in interface java.util.function.Consumer<T>

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface java.io.Flushable

Throws:

java.io.IOException

onReset

protected void onReset()

Description copied from class: StructuralJob

Allow sub classes to do something on reset.

Overrides:

onReset in class StructuralJob<java.lang.Object>

setOf

public void setOf(int index,
                  java.lang.Object child)

Add a child.

Property: of

Description: The components of a Bus.

Required: No, but pointless if missing.

Parameters:

child - A child

getInitialStateOp

protected StateOperator getInitialStateOp()

Description copied from class: StructuralJob

Subclasses must provide the StateOperator that will decide how to evaluate the children's state.

Specified by:

getInitialStateOp in class StructuralJob<java.lang.Object>

Returns:

A State Operator. Must not be null.

getStrategy

public java.util.function.Function<? super java.util.function.Consumer<? super T>[],? extends java.util.function.Consumer<T>> getStrategy()

setStrategy

public void setStrategy(java.util.function.Function<? super java.util.function.Consumer<? super T>[],? extends java.util.function.Consumer<T>> strategy)

getCount

public java.util.concurrent.atomic.AtomicInteger getCount()