org.oddjob.beanbus.destinations

Class Batcher<T>

java.lang.Object

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

Type Parameters:

T - The type of bean being batched.

All Implemented Interfaces:

java.io.Flushable, java.lang.AutoCloseable, java.lang.Runnable, java.util.function.Consumer<T>, BusFilter<T,java.util.Collection<T>>, Outbound<java.util.Collection<T>>

public class Batcher<T>
extends java.lang.Object
implements java.util.function.Consumer<T>, BusFilter<T,java.util.Collection<T>>, java.io.Flushable, java.lang.Runnable, java.lang.AutoCloseable

Description

Provide batching of beans.

Example

Create Batches of 2 beans.

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

Author:

Rob

Constructor Summary

Constructors

Constructor and Description
Batcher()

Method Summary

Modifier and Type	Method and Description
void	accept(T bean)
void	close()
protected void	dispatch() Dispatch the beans.
void	flush()
int	getBatchSize()
int	getCount()
java.lang.String	getName()
int	getSize()
java.util.function.Consumer<? super java.util.Collection<T>>	getTo()
void	reset()
void	run()
void	setBatchSize(int batchSize)
void	setName(java.lang.String name)
void	setTo(java.util.function.Consumer<? super java.util.Collection<T>> next) Set the out bound destination.
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

Constructor Detail

Batcher

public Batcher()

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception

reset

public void reset()

accept

public void accept(T bean)

Specified by:

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

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface java.io.Flushable

Throws:

java.io.IOException

dispatch

protected void dispatch()

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

getCount

public int getCount()

getSize

public int getSize()

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getTo

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

setTo

public void setTo(java.util.function.Consumer<? 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