org.apache.camel.impl
Class DefaultInflightRepository

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.impl.DefaultInflightRepository
All Implemented Interfaces:
Service, ShutdownableService, InflightRepository

public class DefaultInflightRepository
extends ServiceSupport
implements InflightRepository

Default implement which just uses a counter

Version:

Constructor Summary
DefaultInflightRepository()
           
 
Method Summary
 void add(Exchange exchange)
          Adds the exchange to the inflight registry
protected  void doStart()
           
protected  void doStop()
           
 void remove(Exchange exchange)
          Removes the exchange from the inflight registry
 int size()
          Current size of inflight exchanges.
 int size(Endpoint endpoint)
          Current size of inflight exchanges which are from the given endpoint.
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, doResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isSuspended, isSuspending, removeChildService, resume, shutdown, start, start, stop, suspend
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.camel.Service
start, stop
 

Constructor Detail

DefaultInflightRepository

public DefaultInflightRepository()
Method Detail

add

public void add(Exchange exchange)
Description copied from interface: InflightRepository
Adds the exchange to the inflight registry

Specified by:
add in interface InflightRepository
Parameters:
exchange - the exchange

remove

public void remove(Exchange exchange)
Description copied from interface: InflightRepository
Removes the exchange from the inflight registry

Specified by:
remove in interface InflightRepository
Parameters:
exchange - the exchange

size

public int size()
Description copied from interface: InflightRepository
Current size of inflight exchanges.

Will return 0 if there are no inflight exchanges.

Specified by:
size in interface InflightRepository
Returns:
number of exchanges currently in flight.

size

public int size(Endpoint endpoint)
Description copied from interface: InflightRepository
Current size of inflight exchanges which are from the given endpoint.

Will return 0 if there are no inflight exchanges.

Specified by:
size in interface InflightRepository
Parameters:
endpoint - the endpoint where the Exchange are from.
Returns:
number of exchanges currently in flight.

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class ServiceSupport
Throws:
Exception

doStop

protected void doStop()
               throws Exception
Specified by:
doStop in class ServiceSupport
Throws:
Exception


Apache CAMEL