[camel] 04/05: camel-core - Fixed java.util.ConcurrentModificationException when using extended endpoint utilization statistics.

[davsclaus]

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

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

commit c8dd38846531b5df0be262a6f7b890934670ecab
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Apr 5 17:37:18 2021 +0200

    camel-core - Fixed java.util.ConcurrentModificationException when using 
extended endpoint utilization statistics.
---
 .../main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java  | 2 +-
 .../src/main/java/org/apache/camel/processor/WireTapProcessor.java     | 1 -
 .../org/apache/camel/support/DefaultEndpointUtilizationStatistics.java | 3 ++-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/core/camel-api/src/main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java
 
b/core/camel-api/src/main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java
index 990389e..17060fa 100644
--- 
a/core/camel-api/src/main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java
+++ 
b/core/camel-api/src/main/java/org/apache/camel/spi/EndpointUtilizationStatistics.java
@@ -34,7 +34,7 @@ public interface EndpointUtilizationStatistics {
     int size();
 
     /**
-     * Callback when an endpoint is being utilizated by an {@link 
org.apache.camel.Processor} EIP such as sending a
+     * Callback when an endpoint is being utilized by an {@link 
org.apache.camel.Processor} EIP such as sending a
      * message to a dynamic endpoint.
      *
      * @param uri the endpoint uri
diff --git 
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java
 
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java
index f3b90d4..f90f7f2 100644
--- 
a/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java
+++ 
b/core/camel-core-processor/src/main/java/org/apache/camel/processor/WireTapProcessor.java
@@ -44,7 +44,6 @@ import org.apache.camel.spi.RouteIdAware;
 import org.apache.camel.spi.ShutdownAware;
 import org.apache.camel.support.AsyncProcessorConverterHelper;
 import org.apache.camel.support.AsyncProcessorSupport;
-import org.apache.camel.support.DefaultExchange;
 import org.apache.camel.support.service.ServiceHelper;
 import org.apache.camel.util.ObjectHelper;
 import org.slf4j.Logger;
diff --git 
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
 
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
index abea2e1..ae024ec 100644
--- 
a/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
+++ 
b/core/camel-support/src/main/java/org/apache/camel/support/DefaultEndpointUtilizationStatistics.java
@@ -18,6 +18,7 @@ package org.apache.camel.support;
 
 import java.util.Collections;
 import java.util.Map;
+import java.util.concurrent.ConcurrentMap;
 
 import org.apache.camel.spi.EndpointUtilizationStatistics;
 
@@ -43,7 +44,7 @@ public class DefaultEndpointUtilizationStatistics implements 
EndpointUtilization
     }
 
     @Override
-    public void onHit(String uri) {
+    public synchronized void onHit(String uri) {
         map.compute(uri, (key, current) -> {
             if (current == null) {
                 return 1L;