bus:queue

Property Summary

Example Summary

Property Detail

Capacity of the queue before it blocks.

The name of this component.

The number of items taken from the queue.

The number of consumers waiting.

Examples

A simple example.

<oddjob>
    <job>
        <sequential>
            <jobs>
                <variables id="vars">
                    <results>
                        <list/>
                    </results>
                </variables>
                <bean class="org.oddjob.beanbus.destinations.BusQueue" id="queue"/>
                <parallel id="parallel">
                    <jobs>
                        <sequential>
                            <jobs>
                                <bean class="org.oddjob.beanbus.drivers.IterableBusDriver" id="producer" name="Producer">
                                    <values>
                                        <list>
                                            <values>
                                                <value value="apple"/>
                                                <value value="orange"/>
                                                <value value="pear"/>
                                            </values>
                                        </list>
                                    </values>
                                    <to>
                                        <value value="${queue}"/>
                                    </to>
                                </bean>
                                <stop job="${queue}" name="Stop Queue"/>
                            </jobs>
                        </sequential>
                        <bean class="org.oddjob.beanbus.drivers.IterableBusDriver" id="consumer" name="Consumer">
                            <values>
                                <value value="${queue}"/>
                            </values>
                            <to>
                                <value value="${vars.results}"/>
                            </to>
                        </bean>
                    </jobs>
                </parallel>
            </jobs>
        </sequential>
    </job>
</oddjob>

An example in BeanBus.

<oddjob>
    <job>
        <parallel id="parallel" join="true">
            <jobs>
                <bus:bus xmlns:bus="oddjob:beanbus">
                    <of>
                        <bus:driver>
                            <values>
                                <list>
                                    <values>
                                        <value value="Apple"/>
                                        <value value="Orange"/>
                                        <value value="Banana"/>
                                        <value value="Pear"/>
                                        <value value="Kiwi"/>
                                    </values>
                                </list>
                            </values>
                        </bus:driver>
                        <bus:queue id="queue"/>
                    </of>
                </bus:bus>
                <bus:bus xmlns:bus="oddjob:beanbus">
                    <of>
                        <bus:driver>
                            <values>
                                <value value="${queue}"/>
                            </values>
                        </bus:driver>
                        <bus:collect id="results"/>
                    </of>
                </bus:bus>
            </jobs>
        </parallel>
    </job>
</oddjob>