You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@camel.apache.org by "Dan Rivett (JIRA)" <ji...@apache.org> on 2017/03/09 06:14:37 UTC
[jira] [Created] (CAMEL-10972) ProducerCache uses
Endpoint.getEndpointUri() as key which isn't always unique!
Dan Rivett created CAMEL-10972:
----------------------------------
Summary: ProducerCache uses Endpoint.getEndpointUri() as key which isn't always unique!
Key: CAMEL-10972
URL: https://issues.apache.org/jira/browse/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:
{code}
<route id="deadLetterRouteWithMulticast">
<from uri="direct:foo"/>
<multicast>
<to uri="context-a:notifyProcessingFailedRoute" />
<to uri="context-b:notifyProcessingFailedRoute" />
</multicast>
</route>
{code}
This works fine.
However swap to a {{RecipientList}} and it fails:
{code}
<route id="deadLetterRouteWithRecipientList">
<from uri="direct:foo"/>
<setHeader headerName="myRecipientListHeader">
<constant>context-a:notifyProcessingFailedRoute,context-b:notifyProcessingFailedRoute</constant>
</setHeader>
<recipientList delimiter=",">
<header>myRecipientListHeader</header>
</recipientList>
</route>
{code}
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|https://github.com/apache/camel/blob/master/camel-core/src/main/java/org/apache/camel/impl/ProducerCache.java#L564]) should use a key like something as follows to use a cache key that takes into account the {{Endpoint}}'s Camel Context:
{code}
String key = endpoint.getCamelContext().getName() + "_" + endpoint.getEndpointUri();
{code}
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|https://github.com/apache/camel/blob/master/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java#L87]). Seems a bit of a hack.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)