Description
A Queue for beans. A work in progress.Example
A simple example.
<oddjob>
<job>
<sequential>
<jobs>
<variables id="vars">
<queue>
<bean class="org.oddjob.beanbus.destinations.BeanQueue"/>
</queue>
</variables>
<parallel id="parallel">
<jobs>
<bean class="org.oddjob.beanbus.drivers.IterableBusDriver" id="producer" name="Producer">
<beans>
<list>
<values>
<value value="apple"/>
<value value="orange"/>
<value value="pear"/>
</values>
</list>
</beans>
<to>
<value value="${vars.queue}"/>
</to>
</bean>
<bean class="org.oddjob.beanbus.drivers.IterableBusDriver" id="consumer" name="Consumer">
<beans>
<value value="${vars.queue}"/>
</beans>
<to>
<list/>
</to>
</bean>
</jobs>
</parallel>
</jobs>
</sequential>
</job>
</oddjob>
Example
An example in BeanBus.
<oddjob>
<job>
<parallel id="parallel" join="true">
<jobs>
<bean-bus>
<parts>
<bus:iterable-driver xmlns:bus="oddjob:beanbus">
<beans>
<list>
<values>
<value value="Apple"/>
<value value="Orange"/>
<value value="Banana"/>
<value value="Pear"/>
<value value="Kiwi"/>
</values>
</list>
</beans>
</bus:iterable-driver>
<bus:bean-queue id="queue" xmlns:bus="oddjob:beanbus"/>
</parts>
</bean-bus>
<bean-bus>
<parts>
<bus:iterable-driver xmlns:bus="oddjob:beanbus">
<beans>
<value value="${queue}"/>
</beans>
</bus:iterable-driver>
<bus:bean-capture id="results" xmlns:bus="oddjob:beanbus"/>
</parts>
</bean-bus>
</jobs>
</parallel>
</job>
</oddjob>
- Author:
- rob