org.oddjob.events

Class When<T>

java.lang.Object

org.oddjob.framework.extend.BaseComponent

org.oddjob.framework.extend.BasePrimary

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

org.oddjob.events.EventJobBase<T>

org.oddjob.events.When<T>

All Implemented Interfaces:

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

public class When<T>
extends EventJobBase<T>

Description

Runs a job when triggered by the arrival of an event. The job will be re-run every time the event arrives. If the job is still running when a new event arrives, the job will attempt to be stopped and rerun. A typical use case would be processing a file when it arrives, but which may be re-sent with more up-to-date information.

Example

Evaluating greengrocer portfolios of fruit when data arrives.

<oddjob id="this">
    <job>
        <sequential>
            <jobs>
                <properties name="Properties">
                    <values>
                        <file file="${some.dir}" key="data.dir"/>
                    </values>
                </properties>
                <bean class="org.oddjob.events.example.FileFactStore" id="factStore" rootDir="${data.dir}"/>
                <events:when id="whenBookList" name="When BookList Available" xmlns:events="oddjob:events">
                    <jobs>
                        <bean class="org.oddjob.events.example.FactSubscriber" factStore="${factStore}" name="Subscribe to BookList" query="BookList:GREENGROCERS"/>
                        <foreach id="forEachBook" name="For Each Book">
                            <values>
                                <value value="${whenBookList.trigger.of.books}"/>
                            </values>
                            <configuration>
                                <inline>
                                    <foreach id="bookName">
                                        <job>
                                            <events:when id="whenBook" name="When ${bookName.current}">
                                                <jobs>
                                                    <bean class="org.oddjob.events.example.FactSubscriber" factStore="${factStore}" name="Subscribe to Book ${bookName.current}" query="Book:${bookName.current}"/>
                                                    <events:when id="priceMatch" name="When Prices for ${bookName.current}">
                                                        <jobs>
                                                            <events:for name="For Each Trade">
                                                                <configuration>
                                                                    <inline>
                                                                        <events id="trade">
                                                                            <job>
                                                                                <bean class="org.oddjob.events.example.FactSubscriber" factStore="${factStore}" name="Subscribe to Price for ${trade.current.product}" query="Price:${trade.current.product}"/>
                                                                            </job>
                                                                        </events>
                                                                    </inline>
                                                                </configuration>
                                                                <values>
                                                                    <value value="${whenBook.trigger.of.trades}"/>
                                                                </values>
                                                            </events:for>
                                                            <sequential name="Run Calculation">
                                                                <jobs>
                                                                    <bean class="org.oddjob.events.example.ValueCalculator" id="calculate">
                                                                        <trades>
                                                                            <value value="${whenBook.trigger.of.trades}"/>
                                                                        </trades>
                                                                        <prices>
                                                                            <value value="${priceMatch.trigger.ofs}"/>
                                                                        </prices>
                                                                    </bean>
                                                                    <echo>Value of ${bookName.current} is ${calculate.value}</echo>
                                                                </jobs>
                                                            </sequential>
                                                        </jobs>
                                                    </events:when>
                                                </jobs>
                                            </events:when>
                                        </job>
                                    </foreach>
                                </inline>
                            </configuration>
                        </foreach>
                    </jobs>
                </events:when>
            </jobs>
        </sequential>
    </job>
</oddjob>

See Also:

Serialized Form

Author:

Rob Gordon.

Field Summary

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

childHelper, destroy, stop, structuralState

Constructor Summary

Constructors

Constructor and Description
When()

Method Summary

Modifier and Type	Method and Description
protected void	onImmediateEvent(T event) Do something with an event received immediately before the subscribe method has returned.
protected void	onLaterEvent(T event, java.lang.Object job, java.util.concurrent.Executor executor) Called when an event is received after subscription.
protected void	onSubscriptionStarted(java.lang.Object job, java.util.concurrent.Executor executor) Called once the subscription has started.
protected StateListener	stateOnChildComplete()

Methods inherited from class org.oddjob.events.EventJobBase

accept, execute, getEventSource, getInitialStateOp, getTo, getTrigger, isBeDestination, onStop, postStop, setBeDestination, setEventSource, setExecutorService, setJobs, setTo, setTrigger, startChildStateReflector, switchToChildStateReflector, unsubscribe

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

addStructuralListener, fireDestroyedState, force, getStateChanger, hardReset, iconHelper, isStop, onDestroy, onHardReset, onReset, onSoftReset, removeStructuralListener, run, softReset, 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

When

public When()

Method Detail

onImmediateEvent

protected void onImmediateEvent(T event)

Description copied from class: EventJobBase

Do something with an event received immediately before the subscribe method has returned.

Specified by:

onImmediateEvent in class EventJobBase<T>

Parameters:

event - The event.

onSubscriptionStarted

protected void onSubscriptionStarted(java.lang.Object job,
                                     java.util.concurrent.Executor executor)

Description copied from class: EventJobBase

Called once the subscription has started.

Specified by:

onSubscriptionStarted in class EventJobBase<T>

Parameters:

job - The job to execute if any.

executor - The executor to use to execute the job.

onLaterEvent

protected void onLaterEvent(T event,
                            java.lang.Object job,
                            java.util.concurrent.Executor executor)

Description copied from class: EventJobBase

Called when an event is received after subscription. There is no guarantee that an this will be called after the EventJobBase.onSubscriptionStarted(Object, Executor) method, implementors are responsible for their own synchronisation if required.

Specified by:

onLaterEvent in class EventJobBase<T>

Parameters:

event - The event.

stateOnChildComplete

protected StateListener stateOnChildComplete()

Specified by:

stateOnChildComplete in class EventJobBase<T>