org.oddjob.beanbus.mega
Class StatefulBusConductorAdapter

java.lang.Object
  extended by org.oddjob.beanbus.AbstractBusConductor
      extended by org.oddjob.beanbus.mega.StatefulBusConductorAdapter
All Implemented Interfaces:
BusConductor

public class StatefulBusConductorAdapter
extends AbstractBusConductor
implements BusConductor

Adapts a Stateful into a .

Author:
rob

Constructor Summary
StatefulBusConductorAdapter(Stateful stateful)
           
 
Method Summary
 void cleanBus()
          Cleaning the bus will cause the trip to end and a new one to begin.
 void close()
          Must be called to remove listener.
 void requestBusStop()
          Request that the bus stop.
 String toString()
           
 
Methods inherited from class org.oddjob.beanbus.AbstractBusConductor
addBusListener, fireBusCrashed, fireBusStarting, fireBusStopping, fireBusStopRequested, fireBusTerminated, fireTripBeginning, fireTripEnding, removeBusListener
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.oddjob.beanbus.BusConductor
addBusListener, removeBusListener
 

Constructor Detail

StatefulBusConductorAdapter

public StatefulBusConductorAdapter(Stateful stateful)
Method Detail

cleanBus

public void cleanBus()
              throws BusCrashException
Description copied from interface: BusConductor
Cleaning the bus will cause the trip to end and a new one to begin. Intended for components such as Batcher so that they can flush the bus.

Specified by:
cleanBus in interface BusConductor
Throws:
BusCrashException

requestBusStop

public void requestBusStop()
Description copied from interface: BusConductor
Request that the bus stop. This may, and probably will, be called asynchronously.

Specified by:
requestBusStop in interface BusConductor

close

public void close()
Must be called to remove listener.


toString

public String toString()
Specified by:
toString in class AbstractBusConductor