[CAMEL-8626] Leaking exchangesInFlightKeys in ManagedRoute

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 2.15.1
• Fix Version/s: 2.15.2, 2.16.0
• Component/s: camel-core

Environment

Java 8 u 40 64 bit, Linux

• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Mateusz Nowakowski
• Created: 13/Apr/15 15:15
• Updated: 20/Apr/15 09:17
• Resolved: 19/Apr/15 07:03

Description

Having a camel context with a single route:

        onException(Throwable.class)
                .handled(true)
                .process(handleException()); // essentially  doing exchange.setException(someConvertedException);

        from("direct:generalFlow")
                .routingSlip(property(GeneralFlowRoute.class.getName()));

started from Spring:

    <camelContext id="flows" xmlns="http://camel.apache.org/schema/spring">
        <template id="template" defaultEndpoint="direct:generalFlow"/>
        <routeBuilder ref="generalFlow"/>
    </camelContext>

    <bean id="generalFlow" class="com.blabla.GeneralFlowRoute"/>

During performance test both exchangesInFlightKeys and exchangesInFlightStartTimestamps are accumulating over time.

But if the test is run in one thread with debug - nothing is accumulated.

Issue found after migration from 2.14.1 to 2.15.1