org.oddjob.beanbus.destinations

Class Batcher<T>

java.lang.Object

org.oddjob.beanbus.AbstractDestination<T>

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

Type Parameters:

T - The type of bean being batched.

All Implemented Interfaces:

java.lang.Iterable<T>, java.util.Collection<T>, BusFilter<T,java.util.Collection<T>>, Outbound<java.util.Collection<T>>

public class Batcher<T>
extends AbstractDestination<T>
implements BusFilter<T,java.util.Collection<T>>

Description

Provide batching of beans.

Example

Create Batches of 2 beans.

<oddjob>
    <job>
        <bean-bus>
            <parts>
                <bus:iterable-driver id="bean-bus" xmlns:bus="oddjob:beanbus">
                    <beans>
                        <list>
                            <values>
                                <value value="Apple"/>
                                <value value="Orange"/>
                                <value value="Pear"/>
                                <value value="Kiwi"/>
                                <value value="Banana"/>
                            </values>
                        </list>
                    </beans>
                </bus:iterable-driver>
                <bean id="batcher" batchSize="2" class="org.oddjob.beanbus.destinations.Batcher"/>
                <bus:bean-capture id="results" xmlns:bus="oddjob:beanbus"/>
            </parts>
        </bean-bus>
    </job>
</oddjob>

Author:

rob

Constructor Summary

Constructors

Constructor and Description
Batcher()

Method Summary

Modifier and Type	Method and Description
boolean	add(T bean)
protected void	dispatch() Dispatch the beans.
int	getBatchSize()
int	getCount()
java.lang.String	getName()
int	getSize()
java.util.Collection<? super java.util.Collection<T>>	getTo()
boolean	isEmpty()
void	setBatchSize(int batchSize)
void	setBeanBus(BusConductor busConductor)
void	setName(java.lang.String name)
void	setTo(java.util.Collection<? super java.util.Collection<T>> next) Set the out bound destination.
java.lang.String	toString()

Methods inherited from class org.oddjob.beanbus.AbstractDestination

addAll, clear, contains, containsAll, iterator, remove, removeAll, retainAll, size, toArray, toArray

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Collection

addAll, clear, contains, containsAll, equals, hashCode, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

Batcher

public Batcher()

Method Detail

add

public boolean add(T bean)

Specified by:

add in interface java.util.Collection<T>

dispatch

protected void dispatch()

Dispatch the beans. Called when a batch is ready of a trip is ending.

setBeanBus

@Inject
public void setBeanBus(BusConductor busConductor)

getCount

public int getCount()

getSize

public int getSize()

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface java.util.Collection<T>

Overrides:

isEmpty in class AbstractDestination<T>

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getTo

public java.util.Collection<? super java.util.Collection<T>> getTo()

setTo

public void setTo(java.util.Collection<? super java.util.Collection<T>> next)

Description copied from interface: Outbound

Set the out bound destination.

Specified by:

setTo in interface Outbound<java.util.Collection<T>>

getName

public java.lang.String getName()

setName

public void setName(java.lang.String name)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object