org.oddjob.beanbus.destinations

Class BusQueue<E>

java.lang.Object

org.oddjob.beanbus.destinations.BusQueue<E>

Type Parameters:

E - The type of element on the queue.

All Implemented Interfaces:

java.lang.Iterable<E>, java.util.function.Consumer<E>, Service, Stoppable

public class BusQueue<E>
extends java.lang.Object
implements java.util.function.Consumer<E>, java.lang.Iterable<E>, Service

Description

A Queue for beans. A work in progress.

Example

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>

Example

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>

Author:

rob

Constructor Summary

Constructors

Constructor and Description
BusQueue()

Method Summary

Modifier and Type	Method and Description
void	accept(E bean)
int	getCapacity()
java.lang.String	getName()
int	getSize()
int	getTaken()
int	getWaitingConsumers()
java.util.Iterator<E>	iterator()
void	onReset()
void	setCapacity(int capacity)
void	setName(java.lang.String name)
void	setPut(E item) Allows an item to be place on the queue with set property.
void	start() Start the service.
void	stop() Stop executing.
java.lang.String	toString()

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 java.lang.Iterable

forEach, spliterator

Constructor Detail

BusQueue

public BusQueue()

Method Detail

start

public void start()

Description copied from interface: Service

Start the service.

Specified by:

start in interface Service

stop

public void stop()

Description copied from interface: Stoppable

Stop executing. This method should not return until the Stoppable has actually stopped.

Specified by:

stop in interface Stoppable

accept

public void accept(E bean)

Specified by:

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

iterator

public java.util.Iterator<E> iterator()

Specified by:

iterator in interface java.lang.Iterable<E>

onReset

public void onReset()

getSize

public int getSize()

Property:

Description: The size of the queue.

Required: Read only.

getName

public java.lang.String getName()

setName

public void setName(java.lang.String name)

getTaken

public int getTaken()

setPut

public void setPut(E item)

Allows an item to be place on the queue with set property.

Parameters:

item - An item.

getCapacity

public int getCapacity()

setCapacity

public void setCapacity(int capacity)

getWaitingConsumers

public int getWaitingConsumers()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object