[camel] branch main updated: Revert "CAMEL-19058: cache the producer and endpoint locally to avoid hitting the type check scalability issue"

[orpiske]

This is an automated email from the ASF dual-hosted git repository.

orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new 907a9d0c08d Revert "CAMEL-19058: cache the producer and endpoint 
locally to avoid hitting the type check scalability issue"
907a9d0c08d is described below

commit 907a9d0c08d40c5308bb440ec9ebaaa4d7544dc4
Author: Otavio Rodolfo Piske <angusyo...@gmail.com>
AuthorDate: Wed Mar 1 07:39:56 2023 +0100

    Revert "CAMEL-19058: cache the producer and endpoint locally to avoid 
hitting the type check scalability issue"
    
    This reverts commit c8d36cb1ddb93331cbecb0efa10586737f1d72c6.
    
    See the notes on CAMEL-19102.
---
 .../org/apache/camel/support/cache/DefaultProducerCache.java | 12 ------------
 1 file changed, 12 deletions(-)

diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/cache/DefaultProducerCache.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/cache/DefaultProducerCache.java
index c8ad9287213..17612316e62 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/cache/DefaultProducerCache.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/cache/DefaultProducerCache.java
@@ -58,9 +58,6 @@ public class DefaultProducerCache extends ServiceSupport 
implements ProducerCach
     private boolean extendedStatistics;
     private int maxCacheSize;
 
-    private Endpoint lastUsedEndpoint;
-    private AsyncProducer lastUsedProducer;
-
     public DefaultProducerCache(Object source, CamelContext camelContext, int 
cacheSize) {
         this.source = source;
         this.camelContext = camelContext;
@@ -122,20 +119,11 @@ public class DefaultProducerCache extends ServiceSupport 
implements ProducerCach
 
     @Override
     public AsyncProducer acquireProducer(Endpoint endpoint) {
-        // Try to favor thread locality as some data in the producer's cache 
may be shared among threads,
-        // triggering cases of false sharing
-        if (endpoint == lastUsedEndpoint) {
-            return lastUsedProducer;
-        }
-
         try {
             AsyncProducer producer = producers.acquire(endpoint);
             if (statistics != null) {
                 statistics.onHit(endpoint.getEndpointUri());
             }
-            lastUsedEndpoint = endpoint;
-            lastUsedProducer = producer;
-
             return producer;
         } catch (Throwable e) {
             throw new FailedToCreateProducerException(endpoint, e);