org.apache.camel.spi
Interface InflightRepository

All Superinterfaces:
Service
All Known Implementing Classes:
DefaultInflightRepository

public interface InflightRepository
extends Service

A repository which tracks in flight Exchanges.

Version:

Method Summary
 void add(Exchange exchange)
          Adds the exchange to the inflight registry
 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 interface org.apache.camel.Service
start, stop
 

Method Detail

add

void add(Exchange exchange)
Adds the exchange to the inflight registry

Parameters:
exchange - the exchange

remove

void remove(Exchange exchange)
Removes the exchange from the inflight registry

Parameters:
exchange - the exchange

size

int size()
Current size of inflight exchanges.

Will return 0 if there are no inflight exchanges.

Returns:
number of exchanges currently in flight.

size

int size(Endpoint endpoint)
Current size of inflight exchanges which are from the given endpoint.

Will return 0 if there are no inflight exchanges.

Parameters:
endpoint - the endpoint where the Exchange are from.
Returns:
number of exchanges currently in flight.


Apache CAMEL