[jira] [Created] (CAMEL-9065) Exchange created needs to be aware of its FROM endpoint.

["omar alles (JIRA)" <ji...@apache.org>]

omar alles created CAMEL-9065:
---------------------------------

             Summary: Exchange created needs to be aware of its FROM endpoint. 
                 Key: CAMEL-9065
                 URL: https://issues.apache.org/jira/browse/CAMEL-9065
             Project: Camel
          Issue Type: Bug
          Components: camel-mongodb
    Affects Versions: 2.15.2
            Reporter: omar alles
            Priority: Minor
             Fix For: 2.16.0


In 2.16, DefaultRuntimeEndpointRegistry (an EventNotifier) is extended to being able to handle ExchangeCreatedEvent s. 
In its notify(EventObjet), when processing an ExchangeCreateEvent, a reference to exchange's from endpoint is needed in order to obtain its endpoint uri. 

{code:title=DefaultRuntimeEndpointRegistry.java|borderStyle=solid}
} else if (extended && event instanceof ExchangeCreatedEvent) {
            // we only capture details in extended mode
            ExchangeCreatedEvent ece = (ExchangeCreatedEvent) event;
            Endpoint endpoint = ece.getExchange().getFromEndpoint();
            String routeId = ece.getExchange().getFromRouteId();
            String uri = endpoint.getEndpointUri();
            String key = asUtilizationKey(routeId, uri);
            if (key != null) {
                inputUtilization.onHit(key);
            }
{code}

The problem is located in MongoDbEndpoint createMongoDbExchange)() 

{code:title=MongoDbEndpoint.java|borderStyle=solid}
public Exchange createMongoDbExchange(DBObject dbObj) {
        Exchange exchange = new DefaultExchange(this.getCamelContext(), getExchangePattern()); 
        ...
    }
{code}

This Exchange constructor does not take into consideration exchange's from endpoint, consequently causing a NPE when processing its associated ExchangeCreatedEvent.

When constructing an exchange,  MongoDbEndpoint should use its parent 's createExchange() which uses the proper Exchange constructors. 

{code:title=MongoDbEndpoint.java|borderStyle=solid}
public Exchange createMongoDbExchange(DBObject dbObj) {
//        Exchange exchange = new DefaultExchange(this.getCamelContext(), getExchangePattern());
        Exchange exchange = super.createExchange();
...
}
{code}




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)