public interface InflightRepository extends StaticService
Exchanges.| Modifier and Type | Interface and Description |
|---|---|
static interface |
InflightRepository.InflightExchange
Information about the inflight exchange.
|
| Modifier and Type | Method and Description |
|---|---|
void |
add(Exchange exchange)
Adds the exchange to the inflight registry to the total counter
|
void |
add(Exchange exchange,
String routeId)
Adds the exchange to the inflight registry associated to the given route
|
Collection<InflightRepository.InflightExchange> |
browse()
A read-only browser of the
InflightRepository.InflightExchanges that are currently inflight. |
Collection<InflightRepository.InflightExchange> |
browse(int limit,
boolean sortByLongestDuration)
A read-only browser of the
InflightRepository.InflightExchanges that are currently inflight. |
void |
remove(Exchange exchange)
Removes the exchange from the inflight registry to the total counter
|
void |
remove(Exchange exchange,
String routeId)
Removes the exchange from the inflight registry removing association to the given route
|
void |
removeRoute(String routeId)
Removes the route from the in flight registry.
|
int |
size()
Current size of inflight exchanges.
|
int |
size(Endpoint endpoint)
Deprecated.
will be removed in a future Camel release.
|
int |
size(String routeId)
Current size of inflight exchanges which are from the given route.
|
void add(Exchange exchange)
exchange - the exchangevoid remove(Exchange exchange)
exchange - the exchangevoid add(Exchange exchange, String routeId)
exchange - the exchangerouteId - the id of the routevoid remove(Exchange exchange, String routeId)
exchange - the exchangerouteId - the id of the routeint size()
@Deprecated int size(Endpoint endpoint)
void removeRoute(String routeId)
routeId - the id of the routeint size(String routeId)
routeId - the id of the routeCollection<InflightRepository.InflightExchange> browse()
InflightRepository.InflightExchanges that are currently inflight.Collection<InflightRepository.InflightExchange> browse(int limit, boolean sortByLongestDuration)
InflightRepository.InflightExchanges that are currently inflight.limit - maximum number of entries to returnsortByLongestDuration - to sort by the longest duration. Set to true to include the exchanges that has been inflight the longest time,
set to false to sort by exchange idApache Camel