org.oddjob.beanbus
Class Batcher<T>

java.lang.Object
  org.oddjob.beanbus.Batcher<T>

All Implemented Interfaces:

BusAware, Destination<T>

public class Batcher<T>
extends Object
implements Destination<T>, BusAware

Constructor Summary

Batcher()

Method Summary

void	accept(T bean)
protected void	dispatch()
BadBeanHandler<List<? super T>>	getBadBeanHandler()
int	getBatchSize()
Destination<List<T>>	getNext()
void	setBadBeanHandler(BadBeanHandler<List<? super T>> badBeanHandler)
void	setBatchSize(int batchSize)
void	setBus(BeanBus driver)
void	setNext(Destination<List<T>> next)

Methods inherited from class java.lang.Object

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

Constructor Detail

Batcher

public Batcher()

Method Detail

accept

public void accept(T bean)
            throws CrashBusException

Specified by:

accept in interface Destination<T>

Throws:

CrashBusException

dispatch

protected void dispatch()
                 throws CrashBusException

Throws:

CrashBusException

setBus

public void setBus(BeanBus driver)

Specified by:

setBus in interface BusAware

getBatchSize

public int getBatchSize()

setBatchSize

public void setBatchSize(int batchSize)

getNext

public Destination<List<T>> getNext()

setNext

public void setNext(Destination<List<T>> next)

getBadBeanHandler

public BadBeanHandler<List<? super T>> getBadBeanHandler()

setBadBeanHandler

public void setBadBeanHandler(BadBeanHandler<List<? super T>> badBeanHandler)