camel-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dan Rivett (JIRA)" <>
Subject [jira] [Created] (CAMEL-10972) ProducerCache uses Endpoint.getEndpointUri() as key which isn't always unique!
Date Thu, 09 Mar 2017 06:14:37 GMT
Dan Rivett created CAMEL-10972:

             Summary: ProducerCache uses Endpoint.getEndpointUri() as key which isn't always
                 Key: CAMEL-10972
             Project: Camel
          Issue Type: Bug
            Reporter: Dan Rivett

h3. Background
When referencing direct endpoints from a different context using the uri {{context:endpointUri}}
such as the following:

<route id="deadLetterRouteWithMulticast">
	<from uri="direct:foo"/>

		<to uri="context-a:notifyProcessingFailedRoute" />
		<to uri="context-b:notifyProcessingFailedRoute" />

This works fine.

However swap to a {{RecipientList}} and it fails:

<route id="deadLetterRouteWithRecipientList">
	<from uri="direct:foo"/>

	<setHeader headerName="myRecipientListHeader">

	<recipientList delimiter=",">

h3. Investigation
This appears to be due to {{ProducerCache}} caching by {{Endpoint.getEndpointUri()}} which
in the case of a {{DirectEndpoint}} both the recipients in the list return the same ({{notifyProcessingFailedRoute}}
in the example above).

Now I don't know the Camel codebase well enough to say if {{DirectEndpoint.getEndpointUri()}}
should return ambiguous URIs in multi-Camel-Context environments, or whether {{ProducerCache.doGetProducer()}}
(see [here|])
should use a key like something as follows to use a cache key that takes into account the
{{Endpoint}}'s Camel Context:

String key = endpoint.getCamelContext().getName() + "_" + endpoint.getEndpointUri();

This seems over-simplistic because endpoints that aren't Camel Context specific such as JMS
could be in the cache multiple times, but at least the correct {{Endpoint}} would be returned
from the cache each time, unlike now.

h3. Workarounds
1. Use different endpoint uris (e.g. prepend context name).
2. Supply the Recipient List with {{Endpoint}}s rather than Strings to avoid parsing the URIs
into Endpoints and running into this issue (see [this line|]).
Seems a bit of a hack.

This message was sent by Atlassian JIRA

View raw message