T
- The type of bean being batched.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
<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>
Constructor and Description |
---|
Batcher() |
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() |
public void run()
run
in interface java.lang.Runnable
public void close() throws java.lang.Exception
close
in interface java.lang.AutoCloseable
java.lang.Exception
public void reset()
public void flush() throws java.io.IOException
flush
in interface java.io.Flushable
java.io.IOException
protected void dispatch()
public int getCount()
public int getSize()
public int getBatchSize()
public void setBatchSize(int batchSize)
public java.util.function.Consumer<? super java.util.Collection<T>> getTo()
public void setTo(java.util.function.Consumer<? super java.util.Collection<T>> next)
Outbound
public java.lang.String getName()
public void setName(java.lang.String name)
public java.lang.String toString()
toString
in class java.lang.Object