InflightRepository - Allow it to track per endpoint as well so a consumer knows
how many in flight exchanges it has
-------------------------------------------------------------------------------------------------------------------
Key: CAMEL-2110
URL: https://issues.apache.org/activemq/browse/CAMEL-2110
Project: Apache Camel
Issue Type: Improvement
Components: camel-core
Reporter: Claus Ibsen
Assignee: Claus Ibsen
Priority: Minor
Fix For: 2.1.0
Add this method
{code}
/**
* Current size of inflight exchanges which are from the given endpoint.
* <p/>
* Will return 0 if there are no inflight exchanges.
*
* @param endpoint the endpoint where the {...@link Exchange} are from.
* @return number of exchanges currently in flight.
*/
int size(Endpoint endpoint);
{code}
To the {{InflightRepository}}.
This allows fine grained tracking of in flight exchanges. Then a given route
and consumer can report the number of exchanges it has in flight.
And we can also use that to help throtteling a consumer to avoid having too
many in flight exchanges.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
